[jira] [Commented] (FLINK-11948) When kafka sink parallelism

2019-03-18 Thread Yun Tang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16794878#comment-16794878 ] Yun Tang commented on FLINK-11948: -- [~bf30075] I think the name {{FlinkFixedPartitioner}} should

[jira] [Commented] (FLINK-11948) When kafka sink parallelism

2019-03-18 Thread qi quan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16794798#comment-16794798 ] qi quan commented on FLINK-11948: - Thank you, but I think it is not appropriate to put this partitioner

[jira] [Commented] (FLINK-11948) When kafka sink parallelism

2019-03-18 Thread Yun Tang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16794767#comment-16794767 ] Yun Tang commented on FLINK-11948: -- I think this is what {{FlinkFixedPartitioner}} wants to achieve.

[jira] [Commented] (FLINK-11948) When kafka sink parallelism

2019-03-18 Thread Congxian Qiu(klion26) (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16794775#comment-16794775 ] Congxian Qiu(klion26) commented on FLINK-11948: --- As the doc said, {noformat} To avoid such