[jira] [Commented] (FLINK-19285) Kafka sql connector fixed partitioner not work

[ https://issues.apache.org/jira/browse/FLINK-19285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17241503#comment-17241503 ] Lyr commented on FLINK-19285: - ok  i understand thank you > Kafka sql connector fixed parti

[jira] [Commented] (FLINK-19285) Kafka sql connector fixed partitioner not work

[ https://issues.apache.org/jira/browse/FLINK-19285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17241490#comment-17241490 ] Dawid Wysakowicz commented on FLINK-19285: -- [~Leiyanrui] I don't think I unders

[jira] [Commented] (FLINK-19285) Kafka sql connector fixed partitioner not work

[ https://issues.apache.org/jira/browse/FLINK-19285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17241483#comment-17241483 ] Lyr commented on FLINK-19285: - I  have fixed this bug in 1.11.1,i want to have a push reques

[jira] [Commented] (FLINK-19285) Kafka sql connector fixed partitioner not work

[ https://issues.apache.org/jira/browse/FLINK-19285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17198160#comment-17198160 ] limbo commented on FLINK-19285: --- [~dwysakowicz] Oh, yes, I find my version is 1.11.0, than

[jira] [Commented] (FLINK-19285) Kafka sql connector fixed partitioner not work

[ https://issues.apache.org/jira/browse/FLINK-19285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17198158#comment-17198158 ] Dawid Wysakowicz commented on FLINK-19285: -- I see you changed the affected vers

[jira] [Commented] (FLINK-19285) Kafka sql connector fixed partitioner not work

[ https://issues.apache.org/jira/browse/FLINK-19285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17198154#comment-17198154 ] limbo commented on FLINK-19285: --- Hi [~jark], thanks very much I set parallelism is 2, and

[jira] [Commented] (FLINK-19285) Kafka sql connector fixed partitioner not work

[ https://issues.apache.org/jira/browse/FLINK-19285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17198149#comment-17198149 ] Dawid Wysakowicz commented on FLINK-19285: -- [~limbo] Could you please double ch

[jira] [Commented] (FLINK-19285) Kafka sql connector fixed partitioner not work

[ https://issues.apache.org/jira/browse/FLINK-19285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17198143#comment-17198143 ] Jark Wu commented on FLINK-19285: - Hi [~limbo], what's the parallelism of your sink? I

[jira] [Commented] (FLINK-19285) Kafka sql connector fixed partitioner not work

[ https://issues.apache.org/jira/browse/FLINK-19285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17198121#comment-17198121 ] limbo commented on FLINK-19285: --- I tracked the code and find that [https://github.com/apa