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

[ https://issues.apache.org/jira/browse/FLINK-10348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16617952#comment-16617952 ] Jiayi Liao commented on FLINK-10348: [~elevy] Ok, what you said makes more sense to

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

[ https://issues.apache.org/jira/browse/FLINK-10348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16617899#comment-16617899 ] Elias Levy commented on FLINK-10348: [~wind_ljy] Re: 1.  The problem is timestamp a

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

[ https://issues.apache.org/jira/browse/FLINK-10348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16617054#comment-16617054 ] Jiayi Liao commented on FLINK-10348: [~elevy] 1. From my perspective, we use fetch

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

[ https://issues.apache.org/jira/browse/FLINK-10348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16616933#comment-16616933 ] Elias Levy commented on FLINK-10348: I would suggest the strategy employed by Kafka

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

[ https://issues.apache.org/jira/browse/FLINK-10348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16616853#comment-16616853 ] Jiayi Liao commented on FLINK-10348: [~twalthr][~Zentol] What do you think of this f