[jira] [Comment Edited] (FLINK-15670) Provide a Kafka Source/Sink pair that aligns Kafka's Partitions and Flink's KeyGroups

2020-05-15 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17108783#comment-17108783 ] Yuan Mei edited comment on FLINK-15670 at 5/16/20, 4:26 AM: Things to follow

[jira] [Comment Edited] (FLINK-15670) Provide a Kafka Source/Sink pair that aligns Kafka's Partitions and Flink's KeyGroups

2020-05-15 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17108783#comment-17108783 ] Yuan Mei edited comment on FLINK-15670 at 5/16/20, 3:44 AM: Things to follow

[jira] [Comment Edited] (FLINK-15670) Provide a Kafka Source/Sink pair that aligns Kafka's Partitions and Flink's KeyGroups

2020-05-15 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17108783#comment-17108783 ] Yuan Mei edited comment on FLINK-15670 at 5/16/20, 2:42 AM: Things to follow

[jira] [Comment Edited] (FLINK-15670) Provide a Kafka Source/Sink pair that aligns Kafka's Partitions and Flink's KeyGroups

2020-05-15 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17108783#comment-17108783 ] Yuan Mei edited comment on FLINK-15670 at 5/16/20, 2:39 AM: Things to follow

[jira] [Comment Edited] (FLINK-15670) Provide a Kafka Source/Sink pair that aligns Kafka's Partitions and Flink's KeyGroups

2020-05-15 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17108783#comment-17108783 ] Yuan Mei edited comment on FLINK-15670 at 5/16/20, 2:38 AM: Things to follow

[jira] [Comment Edited] (FLINK-15670) Provide a Kafka Source/Sink pair that aligns Kafka's Partitions and Flink's KeyGroups

2020-05-15 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17108783#comment-17108783 ] Yuan Mei edited comment on FLINK-15670 at 5/16/20, 12:34 AM: - Things to

[jira] [Comment Edited] (FLINK-15670) Provide a Kafka Source/Sink pair that aligns Kafka's Partitions and Flink's KeyGroups

2020-05-15 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17108783#comment-17108783 ] Yuan Mei edited comment on FLINK-15670 at 5/16/20, 12:33 AM: - Things to

[jira] [Comment Edited] (FLINK-15670) Provide a Kafka Source/Sink pair that aligns Kafka's Partitions and Flink's KeyGroups

2020-05-15 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17108783#comment-17108783 ] Yuan Mei edited comment on FLINK-15670 at 5/16/20, 12:31 AM: - Things to

[jira] [Comment Edited] (FLINK-15670) Provide a Kafka Source/Sink pair that aligns Kafka's Partitions and Flink's KeyGroups

2020-05-15 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17108783#comment-17108783 ] Yuan Mei edited comment on FLINK-15670 at 5/16/20, 12:30 AM: - Things to

[jira] [Comment Edited] (FLINK-15670) Provide a Kafka Source/Sink pair that aligns Kafka's Partitions and Flink's KeyGroups

2020-04-28 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17093323#comment-17093323 ] Yuan Mei edited comment on FLINK-15670 at 4/28/20, 9:10 AM: Thanks [~AHeise] 

[jira] [Comment Edited] (FLINK-15670) Provide a Kafka Source/Sink pair that aligns Kafka's Partitions and Flink's KeyGroups

2020-04-14 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17082909#comment-17082909 ] Yuan Mei edited comment on FLINK-15670 at 4/14/20, 6:40 AM: Pull Request is

[jira] [Comment Edited] (FLINK-15670) Provide a Kafka Source/Sink pair that aligns Kafka's Partitions and Flink's KeyGroups

2020-03-06 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17053232#comment-17053232 ] Yuan Mei edited comment on FLINK-15670 at 3/6/20, 10:50 AM: *Meeting

[jira] [Comment Edited] (FLINK-15670) Provide a Kafka Source/Sink pair that aligns Kafka's Partitions and Flink's KeyGroups

2020-03-06 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17053232#comment-17053232 ] Yuan Mei edited comment on FLINK-15670 at 3/6/20, 10:50 AM: *Meeting

[jira] [Comment Edited] (FLINK-15670) Provide a Kafka Source/Sink pair that aligns Kafka's Partitions and Flink's KeyGroups

2020-03-06 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17053232#comment-17053232 ] Yuan Mei edited comment on FLINK-15670 at 3/6/20, 10:19 AM: *Meeting

[jira] [Comment Edited] (FLINK-15670) Provide a Kafka Source/Sink pair that aligns Kafka's Partitions and Flink's KeyGroups

2020-03-04 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17050031#comment-17050031 ] Yuan Mei edited comment on FLINK-15670 at 3/4/20, 9:11 AM: --- [~sewen] Need to

[jira] [Comment Edited] (FLINK-15670) Provide a Kafka Source/Sink pair that aligns Kafka's Partitions and Flink's KeyGroups

2020-03-04 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17050031#comment-17050031 ] Yuan Mei edited comment on FLINK-15670 at 3/4/20, 9:10 AM: --- [~sewen] Need to

[jira] [Comment Edited] (FLINK-15670) Provide a Kafka Source/Sink pair that aligns Kafka's Partitions and Flink's KeyGroups

2020-03-03 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17050031#comment-17050031 ] Yuan Mei edited comment on FLINK-15670 at 3/4/20, 6:41 AM: --- [~sewen] Need to

[jira] [Comment Edited] (FLINK-15670) Provide a Kafka Source/Sink pair that aligns Kafka's Partitions and Flink's KeyGroups

2020-03-03 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17050031#comment-17050031 ] Yuan Mei edited comment on FLINK-15670 at 3/4/20, 6:37 AM: --- [~sewen] Need to

[jira] [Comment Edited] (FLINK-15670) Provide a Kafka Source/Sink pair that aligns Kafka's Partitions and Flink's KeyGroups

2020-03-03 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17050031#comment-17050031 ] Yuan Mei edited comment on FLINK-15670 at 3/4/20, 6:31 AM: --- [~sewen] Need to

[jira] [Comment Edited] (FLINK-15670) Provide a Kafka Source/Sink pair that aligns Kafka's Partitions and Flink's KeyGroups

2020-02-26 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17045373#comment-17045373 ] Stephan Ewen edited comment on FLINK-15670 at 2/26/20 10:38 AM: I think

[jira] [Comment Edited] (FLINK-15670) Provide a Kafka Source/Sink pair that aligns Kafka's Partitions and Flink's KeyGroups

2020-02-20 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17040874#comment-17040874 ] Yuan Mei edited comment on FLINK-15670 at 2/20/20 11:56 AM: Some updates: I

[jira] [Comment Edited] (FLINK-15670) Provide a Kafka Source/Sink pair that aligns Kafka's Partitions and Flink's KeyGroups

2020-02-12 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17035182#comment-17035182 ] Yuan Mei edited comment on FLINK-15670 at 2/12/20 9:24 AM: ---   I have spent a

[jira] [Comment Edited] (FLINK-15670) Provide a Kafka Source/Sink pair that aligns Kafka's Partitions and Flink's KeyGroups

2020-02-12 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17035182#comment-17035182 ] Yuan Mei edited comment on FLINK-15670 at 2/12/20 9:22 AM: --- {code:java} //

[jira] [Comment Edited] (FLINK-15670) Provide a Kafka Source/Sink pair that aligns Kafka's Partitions and Flink's KeyGroups

2020-02-12 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17035182#comment-17035182 ] Yuan Mei edited comment on FLINK-15670 at 2/12/20 9:17 AM: --- I have spent a

[jira] [Comment Edited] (FLINK-15670) Provide a Kafka Source/Sink pair that aligns Kafka's Partitions and Flink's KeyGroups

2020-01-20 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17019907#comment-17019907 ] Jiangjie Qin edited comment on FLINK-15670 at 1/21/20 7:41 AM: ---

[jira] [Comment Edited] (FLINK-15670) Provide a Kafka Source/Sink pair that aligns Kafka's Partitions and Flink's KeyGroups

2020-01-19 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17019222#comment-17019222 ] Yuan Mei edited comment on FLINK-15670 at 1/20/20 6:15 AM: --- I like this idea.