[jira] [Updated] (FLINK-18626) The result of aggregate SQL on MySQL cannot write to upsert table sink inStreamingMode

[ https://issues.apache.org/jira/browse/FLINK-18626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] gaoling ma updated FLINK-18626: --- Priority: Minor (was: Major) > The result of aggregate SQL on MySQL cannot write to upsert table

[jira] [Comment Edited] (FLINK-18626) The result of aggregate SQL on MySQL cannot write to upsert table sink inStreamingMode

[ https://issues.apache.org/jira/browse/FLINK-18626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17161642#comment-17161642 ] gaoling ma edited comment on FLINK-18626 at 7/21/20, 1:18 AM: -- When I added

[jira] [Commented] (FLINK-18626) The result of aggregate SQL on MySQL cannot write to upsert table sink inStreamingMode

[ https://issues.apache.org/jira/browse/FLINK-18626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17161642#comment-17161642 ] gaoling ma commented on FLINK-18626: When I added System.in.read() after the executeSql method to

[jira] [Updated] (FLINK-18626) The result of aggregate SQL on MySQL cannot write to upsert table sink inStreamingMode

[ https://issues.apache.org/jira/browse/FLINK-18626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] gaoling ma updated FLINK-18626: --- Description: {code:java} StreamExecutionEnvironment bsEnv =

[jira] [Updated] (FLINK-18626) The result of aggregate SQL on MySQL cannot write to upsert table sink in

[ https://issues.apache.org/jira/browse/FLINK-18626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] gaoling ma updated FLINK-18626: --- Summary: The result of aggregate SQL on MySQL cannot write to upsert table sink in (was: The

[jira] [Updated] (FLINK-18626) The result of aggregate SQL on MySQL cannot write to upsert table sink inStreamingMode

[ https://issues.apache.org/jira/browse/FLINK-18626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] gaoling ma updated FLINK-18626: --- Summary: The result of aggregate SQL on MySQL cannot write to upsert table sink inStreamingMode

[jira] [Updated] (FLINK-18626) The result of aggregate SQL on MySQL cannot write to upsert table sink

[ https://issues.apache.org/jira/browse/FLINK-18626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] gaoling ma updated FLINK-18626: --- Description: {code:java} StreamExecutionEnvironment bsEnv =

[jira] [Updated] (FLINK-18626) The result of aggregate SQL on MySQL cannot write to upsert table sink

[ https://issues.apache.org/jira/browse/FLINK-18626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] gaoling ma updated FLINK-18626: --- Summary: The result of aggregate SQL on MySQL cannot write to upsert table sink (was: the result

[jira] [Updated] (FLINK-18626) the result of aggregate SQL on bounded streaming cannot write to upsert table sink

[ https://issues.apache.org/jira/browse/FLINK-18626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] gaoling ma updated FLINK-18626: --- Description: {code:java} StreamExecutionEnvironment bsEnv =

[jira] [Updated] (FLINK-18626) the result of aggregate SQL on bounded streaming cannot write to upsert table sink

[ https://issues.apache.org/jira/browse/FLINK-18626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] gaoling ma updated FLINK-18626: --- Summary: the result of aggregate SQL on bounded streaming cannot write to upsert table sink (was:

[jira] [Commented] (FLINK-18481) Kafka connector can't select data

[ https://issues.apache.org/jira/browse/FLINK-18481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17159903#comment-17159903 ] gaoling ma commented on FLINK-18481: If there is an exception of TableResult.print() when checkpoint

[jira] [Updated] (FLINK-18626) the result of aggregate SQL on streaming cannot write to upsert table sink

[ https://issues.apache.org/jira/browse/FLINK-18626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] gaoling ma updated FLINK-18626: --- Description: {code:java} StreamExecutionEnvironment bsEnv =

[jira] [Updated] (FLINK-18626) the result of aggregate SQL on streaming cannot write to upsert table sink

[ https://issues.apache.org/jira/browse/FLINK-18626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] gaoling ma updated FLINK-18626: --- Issue Type: Bug (was: Improvement) > the result of aggregate SQL on streaming cannot write to

[jira] [Created] (FLINK-18626) the result of aggregate SQL on streaming cannot write to upsert table sink

gaoling ma created FLINK-18626: -- Summary: the result of aggregate SQL on streaming cannot write to upsert table sink Key: FLINK-18626 URL: https://issues.apache.org/jira/browse/FLINK-18626 Project:

[jira] [Commented] (FLINK-18481) Kafka connector can't select data

[ https://issues.apache.org/jira/browse/FLINK-18481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17159828#comment-17159828 ] gaoling ma commented on FLINK-18481: bsEnv.enableCheckpointing(10); I added one line code above and

[jira] [Comment Edited] (FLINK-18481) Kafka connector can't select data

[ https://issues.apache.org/jira/browse/FLINK-18481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17159596#comment-17159596 ] gaoling ma edited comment on FLINK-18481 at 7/17/20, 9:34 AM: --

[jira] [Commented] (FLINK-18481) Kafka connector can't select data

[ https://issues.apache.org/jira/browse/FLINK-18481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17159596#comment-17159596 ] gaoling ma commented on FLINK-18481: StreamExecutionEnvironment bsEnv =