You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Leon Hao (Jira)" <ji...@apache.org> on 2021/04/27 11:55:00 UTC

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

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)