[jira] [Commented] (FLINK-17459) JDBCAppendTableSink not support flush by flushIntervalMills

[ https://issues.apache.org/jira/browse/FLINK-17459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17100533#comment-17100533 ] ranqiqiang commented on FLINK-17459: Thanks [~jark]:            I get  it . If want to do  sink

[jira] [Commented] (FLINK-17459) JDBCAppendTableSink not support flush by flushIntervalMills

[ https://issues.apache.org/jira/browse/FLINK-17459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17100519#comment-17100519 ] Jark Wu commented on FLINK-17459: - The suggested way is to create the jdbc table using DDL. >

[jira] [Commented] (FLINK-17459) JDBCAppendTableSink not support flush by flushIntervalMills

[ https://issues.apache.org/jira/browse/FLINK-17459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17100513#comment-17100513 ] ranqiqiang commented on FLINK-17459: Thanks [~jark] :             I  used  StreamTableEnvironment,

[jira] [Commented] (FLINK-17459) JDBCAppendTableSink not support flush by flushIntervalMills

[ https://issues.apache.org/jira/browse/FLINK-17459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17100442#comment-17100442 ] Jark Wu commented on FLINK-17459: - Hi [~michael ran], here is an example: {code:java}

[jira] [Commented] (FLINK-17459) JDBCAppendTableSink not support flush by flushIntervalMills

[ https://issues.apache.org/jira/browse/FLINK-17459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17100433#comment-17100433 ] ranqiqiang commented on FLINK-17459: [~jark]  can you give an example by JDBCUpsertTableSink  to

[jira] [Commented] (FLINK-17459) JDBCAppendTableSink not support flush by flushIntervalMills

[ https://issues.apache.org/jira/browse/FLINK-17459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17096221#comment-17096221 ] ranqiqiang commented on FLINK-17459: Thanks , Maybe I did wrong ! use JDBCUpsertTableSink to append 

[jira] [Commented] (FLINK-17459) JDBCAppendTableSink not support flush by flushIntervalMills

[ https://issues.apache.org/jira/browse/FLINK-17459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17096120#comment-17096120 ] Jark Wu commented on FLINK-17459: - {code:java} sink.setIsAppendOnly(true); sink.setKeyFields(new

[jira] [Commented] (FLINK-17459) JDBCAppendTableSink not support flush by flushIntervalMills

[ https://issues.apache.org/jira/browse/FLINK-17459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17096029#comment-17096029 ] ranqiqiang commented on FLINK-17459: 1.JDBCAppendTableSink will be abandoned ?

[jira] [Commented] (FLINK-17459) JDBCAppendTableSink not support flush by flushIntervalMills

[ https://issues.apache.org/jira/browse/FLINK-17459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17095458#comment-17095458 ] Jark Wu commented on FLINK-17459: - We suggest to use {{JDBCUpsertTableSink}} in Table API & SQL which