[jira] [Commented] (FLINK-8484) Kinesis consumer re-reads closed shards on job restart

[ https://issues.apache.org/jira/browse/FLINK-8484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16354385#comment-16354385 ] Tzu-Li (Gordon) Tai commented on FLINK-8484: Merged. 1.5 - 140bb0c66257d5d09d

[jira] [Commented] (FLINK-8484) Kinesis consumer re-reads closed shards on job restart

[ https://issues.apache.org/jira/browse/FLINK-8484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16354360#comment-16354360 ] ASF GitHub Bot commented on FLINK-8484: --- Github user asfgit closed the pull request

[jira] [Commented] (FLINK-8484) Kinesis consumer re-reads closed shards on job restart

[ https://issues.apache.org/jira/browse/FLINK-8484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16348414#comment-16348414 ] ASF GitHub Bot commented on FLINK-8484: --- Github user pluppens commented on the issue

[jira] [Commented] (FLINK-8484) Kinesis consumer re-reads closed shards on job restart

[ https://issues.apache.org/jira/browse/FLINK-8484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16348395#comment-16348395 ] ASF GitHub Bot commented on FLINK-8484: --- Github user tzulitai commented on the issue

[jira] [Commented] (FLINK-8484) Kinesis consumer re-reads closed shards on job restart

[ https://issues.apache.org/jira/browse/FLINK-8484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16348374#comment-16348374 ] ASF GitHub Bot commented on FLINK-8484: --- Github user tzulitai commented on the issue

[jira] [Commented] (FLINK-8484) Kinesis consumer re-reads closed shards on job restart

[ https://issues.apache.org/jira/browse/FLINK-8484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16348367#comment-16348367 ] ASF GitHub Bot commented on FLINK-8484: --- Github user pluppens commented on the issue

[jira] [Commented] (FLINK-8484) Kinesis consumer re-reads closed shards on job restart

[ https://issues.apache.org/jira/browse/FLINK-8484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16347093#comment-16347093 ] ASF GitHub Bot commented on FLINK-8484: --- Github user tzulitai commented on the issue

[jira] [Commented] (FLINK-8484) Kinesis consumer re-reads closed shards on job restart

[ https://issues.apache.org/jira/browse/FLINK-8484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16347085#comment-16347085 ] ASF GitHub Bot commented on FLINK-8484: --- Github user pluppens commented on the issue

[jira] [Commented] (FLINK-8484) Kinesis consumer re-reads closed shards on job restart

[ https://issues.apache.org/jira/browse/FLINK-8484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16346809#comment-16346809 ] ASF GitHub Bot commented on FLINK-8484: --- Github user tzulitai commented on the issue

[jira] [Commented] (FLINK-8484) Kinesis consumer re-reads closed shards on job restart

[ https://issues.apache.org/jira/browse/FLINK-8484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16342608#comment-16342608 ] ASF GitHub Bot commented on FLINK-8484: --- Github user pluppens commented on the issue

[jira] [Commented] (FLINK-8484) Kinesis consumer re-reads closed shards on job restart

[ https://issues.apache.org/jira/browse/FLINK-8484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16338913#comment-16338913 ] ASF GitHub Bot commented on FLINK-8484: --- Github user pluppens commented on the issue

[jira] [Commented] (FLINK-8484) Kinesis consumer re-reads closed shards on job restart

[ https://issues.apache.org/jira/browse/FLINK-8484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16338292#comment-16338292 ] ASF GitHub Bot commented on FLINK-8484: --- Github user bowenli86 commented on the issu

[jira] [Commented] (FLINK-8484) Kinesis consumer re-reads closed shards on job restart

[ https://issues.apache.org/jira/browse/FLINK-8484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16337346#comment-16337346 ] ASF GitHub Bot commented on FLINK-8484: --- Github user pluppens commented on the issue

[jira] [Commented] (FLINK-8484) Kinesis consumer re-reads closed shards on job restart

[ https://issues.apache.org/jira/browse/FLINK-8484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16337274#comment-16337274 ] ASF GitHub Bot commented on FLINK-8484: --- Github user tzulitai commented on the issue

[jira] [Commented] (FLINK-8484) Kinesis consumer re-reads closed shards on job restart

[ https://issues.apache.org/jira/browse/FLINK-8484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16337248#comment-16337248 ] ASF GitHub Bot commented on FLINK-8484: --- Github user tzulitai commented on the issue

[jira] [Commented] (FLINK-8484) Kinesis consumer re-reads closed shards on job restart

[ https://issues.apache.org/jira/browse/FLINK-8484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16336396#comment-16336396 ] ASF GitHub Bot commented on FLINK-8484: --- Github user bowenli86 commented on the issu

[jira] [Commented] (FLINK-8484) Kinesis consumer re-reads closed shards on job restart

[ https://issues.apache.org/jira/browse/FLINK-8484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16336373#comment-16336373 ] ASF GitHub Bot commented on FLINK-8484: --- Github user StephanEwen commented on the is

[jira] [Commented] (FLINK-8484) Kinesis consumer re-reads closed shards on job restart

[ https://issues.apache.org/jira/browse/FLINK-8484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16336041#comment-16336041 ] ASF GitHub Bot commented on FLINK-8484: --- Github user pluppens commented on the issue

[jira] [Commented] (FLINK-8484) Kinesis consumer re-reads closed shards on job restart

[ https://issues.apache.org/jira/browse/FLINK-8484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16335765#comment-16335765 ] ASF GitHub Bot commented on FLINK-8484: --- Github user tzulitai commented on the issue

[jira] [Commented] (FLINK-8484) Kinesis consumer re-reads closed shards on job restart

[ https://issues.apache.org/jira/browse/FLINK-8484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16335762#comment-16335762 ] ASF GitHub Bot commented on FLINK-8484: --- Github user pluppens commented on the issue

[jira] [Commented] (FLINK-8484) Kinesis consumer re-reads closed shards on job restart

[ https://issues.apache.org/jira/browse/FLINK-8484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16335726#comment-16335726 ] ASF GitHub Bot commented on FLINK-8484: --- Github user pluppens commented on the issue

[jira] [Commented] (FLINK-8484) Kinesis consumer re-reads closed shards on job restart

[ https://issues.apache.org/jira/browse/FLINK-8484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16335703#comment-16335703 ] ASF GitHub Bot commented on FLINK-8484: --- Github user tzulitai commented on the issue

[jira] [Commented] (FLINK-8484) Kinesis consumer re-reads closed shards on job restart

[ https://issues.apache.org/jira/browse/FLINK-8484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16335691#comment-16335691 ] ASF GitHub Bot commented on FLINK-8484: --- Github user pluppens commented on the issue

[jira] [Commented] (FLINK-8484) Kinesis consumer re-reads closed shards on job restart

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

[jira] [Commented] (FLINK-8484) Kinesis consumer re-reads closed shards on job restart

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

[jira] [Commented] (FLINK-8484) Kinesis consumer re-reads closed shards on job restart

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

[jira] [Commented] (FLINK-8484) Kinesis consumer re-reads closed shards on job restart

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

[jira] [Commented] (FLINK-8484) Kinesis consumer re-reads closed shards on job restart

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

[jira] [Commented] (FLINK-8484) Kinesis consumer re-reads closed shards on job restart

[ https://issues.apache.org/jira/browse/FLINK-8484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16335479#comment-16335479 ] ASF GitHub Bot commented on FLINK-8484: --- GitHub user pluppens opened a pull request: