[GitHub] flink pull request #3253: [FLINK-5606] Remove magic number in key and namesp...

GitHub user dawidwys opened a pull request: https://github.com/apache/flink/pull/3253 [FLINK-5606] Remove magic number in key and namespace serialization Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into considerati

[jira] [Comment Edited] (FLINK-3398) Flink Kafka consumer should support auto-commit opt-outs

[ https://issues.apache.org/jira/browse/FLINK-3398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15849733#comment-15849733 ] Tzu-Li (Gordon) Tai edited comment on FLINK-3398 at 2/2/17 10:13 AM: ---

[jira] [Comment Edited] (FLINK-3398) Flink Kafka consumer should support auto-commit opt-outs

[ https://issues.apache.org/jira/browse/FLINK-3398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15849733#comment-15849733 ] Tzu-Li (Gordon) Tai edited comment on FLINK-3398 at 2/2/17 9:55 AM:

[jira] [Commented] (FLINK-3398) Flink Kafka consumer should support auto-commit opt-outs

[ https://issues.apache.org/jira/browse/FLINK-3398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15849733#comment-15849733 ] Tzu-Li (Gordon) Tai commented on FLINK-3398: I think we should keep this JIRA

[jira] [Comment Edited] (FLINK-3679) DeserializationSchema should handle zero or more outputs for every input

[ https://issues.apache.org/jira/browse/FLINK-3679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15849633#comment-15849633 ] Tzu-Li (Gordon) Tai edited comment on FLINK-3679 at 2/2/17 8:22 AM:

[jira] [Comment Edited] (FLINK-3679) DeserializationSchema should handle zero or more outputs for every input

[ https://issues.apache.org/jira/browse/FLINK-3679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15849633#comment-15849633 ] Tzu-Li (Gordon) Tai edited comment on FLINK-3679 at 2/2/17 8:22 AM:

[jira] [Comment Edited] (FLINK-3679) DeserializationSchema should handle zero or more outputs for every input

[ https://issues.apache.org/jira/browse/FLINK-3679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15849633#comment-15849633 ] Tzu-Li (Gordon) Tai edited comment on FLINK-3679 at 2/2/17 8:22 AM:

[jira] [Created] (FLINK-5697) Add per-shard watermarks for FlinkKinesisConsumer

Tzu-Li (Gordon) Tai created FLINK-5697: -- Summary: Add per-shard watermarks for FlinkKinesisConsumer Key: FLINK-5697 URL: https://issues.apache.org/jira/browse/FLINK-5697 Project: Flink I

[jira] [Comment Edited] (FLINK-3679) DeserializationSchema should handle zero or more outputs for every input

[ https://issues.apache.org/jira/browse/FLINK-3679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15849633#comment-15849633 ] Tzu-Li (Gordon) Tai edited comment on FLINK-3679 at 2/2/17 8:16 AM:

[jira] [Commented] (FLINK-3679) DeserializationSchema should handle zero or more outputs for every input

[ https://issues.apache.org/jira/browse/FLINK-3679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15849633#comment-15849633 ] Tzu-Li (Gordon) Tai commented on FLINK-3679: Hi [~wheat9]! Thank you for picki

[jira] [Commented] (FLINK-4574) Strengthen fetch interval implementation in Kinesis consumer

[ https://issues.apache.org/jira/browse/FLINK-4574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15849621#comment-15849621 ] ASF GitHub Bot commented on FLINK-4574: --- Github user tzulitai commented on a diff in

[jira] [Commented] (FLINK-4574) Strengthen fetch interval implementation in Kinesis consumer

[ https://issues.apache.org/jira/browse/FLINK-4574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15849628#comment-15849628 ] ASF GitHub Bot commented on FLINK-4574: --- Github user tzulitai commented on a diff in

[jira] [Commented] (FLINK-4574) Strengthen fetch interval implementation in Kinesis consumer

[ https://issues.apache.org/jira/browse/FLINK-4574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15849627#comment-15849627 ] ASF GitHub Bot commented on FLINK-4574: --- Github user tzulitai commented on a diff in

[jira] [Commented] (FLINK-4574) Strengthen fetch interval implementation in Kinesis consumer

[ https://issues.apache.org/jira/browse/FLINK-4574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15849619#comment-15849619 ] ASF GitHub Bot commented on FLINK-4574: --- Github user tzulitai commented on a diff in

[jira] [Commented] (FLINK-4574) Strengthen fetch interval implementation in Kinesis consumer

[ https://issues.apache.org/jira/browse/FLINK-4574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15849620#comment-15849620 ] ASF GitHub Bot commented on FLINK-4574: --- Github user tzulitai commented on a diff in

[jira] [Commented] (FLINK-4574) Strengthen fetch interval implementation in Kinesis consumer

[ https://issues.apache.org/jira/browse/FLINK-4574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15849623#comment-15849623 ] ASF GitHub Bot commented on FLINK-4574: --- Github user tzulitai commented on a diff in

[jira] [Commented] (FLINK-4574) Strengthen fetch interval implementation in Kinesis consumer

[ https://issues.apache.org/jira/browse/FLINK-4574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15849618#comment-15849618 ] ASF GitHub Bot commented on FLINK-4574: --- Github user tzulitai commented on a diff in

[jira] [Commented] (FLINK-4574) Strengthen fetch interval implementation in Kinesis consumer

[ https://issues.apache.org/jira/browse/FLINK-4574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15849625#comment-15849625 ] ASF GitHub Bot commented on FLINK-4574: --- Github user tzulitai commented on a diff in

[GitHub] flink pull request #2925: [FLINK-4574] [kinesis] Strengthen fetch interval i...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/2925#discussion_r99067629 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardConsumer.java --- @@ -203,6 +2

[jira] [Commented] (FLINK-4574) Strengthen fetch interval implementation in Kinesis consumer

[ https://issues.apache.org/jira/browse/FLINK-4574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15849626#comment-15849626 ] ASF GitHub Bot commented on FLINK-4574: --- Github user tzulitai commented on a diff in

[GitHub] flink pull request #2925: [FLINK-4574] [kinesis] Strengthen fetch interval i...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/2925#discussion_r99066877 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardConsumer.java --- @@ -154,42 +

[GitHub] flink pull request #2925: [FLINK-4574] [kinesis] Strengthen fetch interval i...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/2925#discussion_r99067395 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardConsumer.java --- @@ -154,42 +

[GitHub] flink pull request #2925: [FLINK-4574] [kinesis] Strengthen fetch interval i...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/2925#discussion_r99067569 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardConsumer.java --- @@ -154,42 +

[GitHub] flink pull request #2925: [FLINK-4574] [kinesis] Strengthen fetch interval i...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/2925#discussion_r95134466 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardConsumer.java --- @@ -154,42 +

[GitHub] flink pull request #2925: [FLINK-4574] [kinesis] Strengthen fetch interval i...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/2925#discussion_r99065929 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardConsumer.java --- @@ -154,42 +

[jira] [Commented] (FLINK-4574) Strengthen fetch interval implementation in Kinesis consumer

[ https://issues.apache.org/jira/browse/FLINK-4574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15849624#comment-15849624 ] ASF GitHub Bot commented on FLINK-4574: --- Github user tzulitai commented on a diff in

[GitHub] flink pull request #2925: [FLINK-4574] [kinesis] Strengthen fetch interval i...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/2925#discussion_r95132586 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardConsumer.java --- @@ -88,6 +96

[jira] [Commented] (FLINK-4574) Strengthen fetch interval implementation in Kinesis consumer

[ https://issues.apache.org/jira/browse/FLINK-4574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15849622#comment-15849622 ] ASF GitHub Bot commented on FLINK-4574: --- Github user tzulitai commented on a diff in

[GitHub] flink pull request #2925: [FLINK-4574] [kinesis] Strengthen fetch interval i...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/2925#discussion_r99065974 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardConsumer.java --- @@ -154,42 +

[GitHub] flink pull request #2925: [FLINK-4574] [kinesis] Strengthen fetch interval i...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/2925#discussion_r95133373 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardConsumer.java --- @@ -107,27 +

[GitHub] flink pull request #2925: [FLINK-4574] [kinesis] Strengthen fetch interval i...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/2925#discussion_r99067451 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardConsumer.java --- @@ -154,42 +

[GitHub] flink pull request #2925: [FLINK-4574] [kinesis] Strengthen fetch interval i...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/2925#discussion_r99066645 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardConsumer.java --- @@ -154,42 +

<    1   2