[jira] [Commented] (FLINK-10348) Solve data skew when consuming data from kafka

2018-09-17 Thread Jiayi Liao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16617952#comment-16617952 ] Jiayi Liao commented on FLINK-10348: [~elevy] Ok, what you said makes more sense to me, I can agree

[jira] [Commented] (FLINK-10348) Solve data skew when consuming data from kafka

2018-09-17 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16617899#comment-16617899 ] Elias Levy commented on FLINK-10348: [~wind_ljy] Re: 1.  The problem is timestamp alignment.  

[jira] [Commented] (FLINK-10348) Solve data skew when consuming data from kafka

2018-09-16 Thread Jiayi Liao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16617054#comment-16617054 ] Jiayi Liao commented on FLINK-10348: [~elevy] 1. From my perspective, we use fetch request to

[jira] [Commented] (FLINK-10348) Solve data skew when consuming data from kafka

2018-09-16 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16616933#comment-16616933 ] Elias Levy commented on FLINK-10348: I would suggest the strategy employed by Kafka Streams, which

[jira] [Commented] (FLINK-10348) Solve data skew when consuming data from kafka

2018-09-16 Thread Jiayi Liao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16616853#comment-16616853 ] Jiayi Liao commented on FLINK-10348: [~twalthr][~Zentol] What do you think of this feature? > Solve