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

[Leon Hao (Jira)]

    [ 
https://issues.apache.org/jira/browse/FLINK-22491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17341232#comment-17341232
 ] 

Leon Hao commented on FLINK-22491:
----------------------------------

will anyone review this?

> 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
>            Priority: Major
>              Labels: performance
>
> 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)