[FLINK-22491] JdbcBatchingOutputFormat checks size of buffer in TableBufferReducedStatementExecutor

• Type: Improvement
• Status: Open
• Priority: Not a Priority
• Resolution: Unresolved
• Component/s: Connectors / JDBC
• Labels: auto-deprioritized-major auto-deprioritized-minor performance
• Assignee: Unassigned
• Reporter: Leon Hao
• Created: 27/Apr/21 11:54
• Updated: 22/Dec/21 10:39

Description

Current code checks batchCount instead of size of buffer in TableBufferReducedStatementExecutor. So if there are a lot of updates in the stream JdbcBatchingOutputFormat will flush too early before the hash map is full.