[jira] [Created] (FLINK-22491) JdbcBatchingOutputFormat checks size of buffer in TableBufferReducedStatementExecutor

[Shang Yuanchun (Jira)]

Leon Hao created FLINK-22491:
--------------------------------

             Summary: JdbcBatchingOutputFormat checks size of buffer in TableBufferReducedStatementExecutor
                 Key: FLINK-22491
                 URL: https://issues.apache.org/jira/browse/FLINK-22491
             Project: Flink
          Issue Type: Improvement
          Components: Connectors / JDBC
            Reporter: Leon Hao


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.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)