[ https://issues.apache.org/jira/browse/FLINK-17459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17100513#comment-17100513 ]
ranqiqiang commented on FLINK-17459: ------------------------------------ Thanks [~jark] : I used StreamTableEnvironment, but the method is deprecated ! {code:java} StreamTableEnvironment tableEnv = StreamTableEnvironment.create(env, bsSettings); // DemoSource extends RichSourceFunction {...} DemoSource source = new DemoSource(); DataStreamSource streamSource = env.addSource(source); tableEnv.createTemporaryView("test",streamSource); // @Deprecated tableEnv.registerTableSink("jdbc_sink", sink); // have any other method ? maybe I used wrong?{code} > JDBCAppendTableSink not support flush by flushIntervalMills > -------------------------------------------------------------- > > Key: FLINK-17459 > URL: https://issues.apache.org/jira/browse/FLINK-17459 > Project: Flink > Issue Type: Improvement > Components: Connectors / JDBC > Affects Versions: 1.10.0 > Reporter: ranqiqiang > Priority: Major > > {{JDBCAppendTableSink just support append by > "JDBCAppendTableSinkBuilder#batchSize",}}{{not support like > "JDBCUpsertTableSink#flushIntervalMills"}} > > {{If batchSize=5000 , my data rows=5000*N+1 ,then last one record could not > be append !!}} -- This message was sent by Atlassian Jira (v8.3.4#803005)