[jira] [Commented] (FLINK-6365) Adapt default values of the Kinesis connector

2017-07-23 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16097956#comment-16097956 ] Tzu-Li (Gordon) Tai commented on FLINK-6365: Thanks for the discussions and co

[jira] [Commented] (FLINK-6365) Adapt default values of the Kinesis connector

2017-07-19 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16094169#comment-16094169 ] Bowen Li commented on FLINK-6365: - Cool! Glad we reached a consensus, and I can proceed wi

[jira] [Commented] (FLINK-6365) Adapt default values of the Kinesis connector

2017-07-19 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16094159#comment-16094159 ] Tzu-Li (Gordon) Tai commented on FLINK-6365: Alright, I think [~sthm] definite

[jira] [Commented] (FLINK-6365) Adapt default values of the Kinesis connector

2017-07-19 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16094156#comment-16094156 ] Bowen Li commented on FLINK-6365: - Ok. For {{SHARD_GETRECORDS_MAX}}, {{10,000}} it is, sin

[jira] [Commented] (FLINK-6365) Adapt default values of the Kinesis connector

2017-07-19 Thread Steffen Hausmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16093722#comment-16093722 ] Steffen Hausmann commented on FLINK-6365: - I agree to adapting SHARD_GETRECORDS_MA

[jira] [Commented] (FLINK-6365) Adapt default values of the Kinesis connector

2017-07-19 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16093358#comment-16093358 ] Tzu-Li (Gordon) Tai commented on FLINK-6365: [~phoenixjiangnan] [~StephanEwen]

[jira] [Commented] (FLINK-6365) Adapt default values of the Kinesis connector

2017-07-19 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16093335#comment-16093335 ] Stephan Ewen commented on FLINK-6365: - Sounds reasonable to me. [~tzulitai] What do y

[jira] [Commented] (FLINK-6365) Adapt default values of the Kinesis connector

2017-07-14 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16088020#comment-16088020 ] Bowen Li commented on FLINK-6365: - We ran into this issue, too. 100 is too small for SHARD