[jira] [Commented] (FLINK-22281) flink sql consumer kakfa canal-json message then sum(amount)

[ https://issues.apache.org/jira/browse/FLINK-22281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321917#comment-17321917 ] xx chai commented on FLINK-22281: - Yes, I have added this parameter correctly > flink sql consumer

[jira] [Commented] (FLINK-22281) flink sql consumer kakfa canal-json message then sum(amount)

[ https://issues.apache.org/jira/browse/FLINK-22281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321914#comment-17321914 ] Jark Wu commented on FLINK-22281: - [~chaixiaoxue] you should add the configuration by

[jira] [Commented] (FLINK-22281) flink sql consumer kakfa canal-json message then sum(amount)

[ https://issues.apache.org/jira/browse/FLINK-22281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321878#comment-17321878 ] xx chai commented on FLINK-22281: - thanks [~jark] I solve the question . > flink sql consumer kakfa

[jira] [Commented] (FLINK-22281) flink sql consumer kakfa canal-json message then sum(amount)

[ https://issues.apache.org/jira/browse/FLINK-22281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321856#comment-17321856 ] xx chai commented on FLINK-22281: - i add the Parameter

[jira] [Commented] (FLINK-22281) flink sql consumer kakfa canal-json message then sum(amount)

[ https://issues.apache.org/jira/browse/FLINK-22281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321850#comment-17321850 ] Jark Wu commented on FLINK-22281: - If you don't have the full historical data, only the incremental