[jira] [Commented] (FLINK-4341) Kinesis connector does not emit maximum watermark properly

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

[jira] [Commented] (FLINK-4341) Kinesis connector does not emit maximum watermark properly

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

[jira] [Commented] (FLINK-4341) Kinesis connector does not emit maximum watermark properly

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

[jira] [Commented] (FLINK-4341) Kinesis connector does not emit maximum watermark properly

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

[jira] [Commented] (FLINK-4341) Kinesis connector does not emit maximum watermark properly

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

[jira] [Commented] (FLINK-4341) Kinesis connector does not emit maximum watermark properly

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

[jira] [Commented] (FLINK-4341) Kinesis connector does not emit maximum watermark properly

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

[jira] [Commented] (FLINK-4341) Kinesis connector does not emit maximum watermark properly

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

[jira] [Commented] (FLINK-4341) Kinesis connector does not emit maximum watermark properly

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

[jira] [Commented] (FLINK-4341) Kinesis connector does not emit maximum watermark properly

[ https://issues.apache.org/jira/browse/FLINK-4341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15433850#comment-15433850 ] Tzu-Li (Gordon) Tai commented on FLINK-4341: I agree. I've been trying around for the past few

[jira] [Commented] (FLINK-4341) Kinesis connector does not emit maximum watermark properly

[ https://issues.apache.org/jira/browse/FLINK-4341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15433114#comment-15433114 ] Robert Metzger commented on FLINK-4341: --- For the short term: I think we have to disable the

[jira] [Commented] (FLINK-4341) Kinesis connector does not emit maximum watermark properly

[ https://issues.apache.org/jira/browse/FLINK-4341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15428584#comment-15428584 ] Scott Kidder commented on FLINK-4341: - FYI, I've confirmed that explicitly setting the parallelism on

[jira] [Commented] (FLINK-4341) Kinesis connector does not emit maximum watermark properly

[ https://issues.apache.org/jira/browse/FLINK-4341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15427912#comment-15427912 ] Stephan Ewen commented on FLINK-4341: - [~aljoscha] This is probably a good long term solution. We

[jira] [Commented] (FLINK-4341) Kinesis connector does not emit maximum watermark properly

[ https://issues.apache.org/jira/browse/FLINK-4341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15426418#comment-15426418 ] Aljoscha Krettek commented on FLINK-4341: - [~tzulitai] We (Stephan and I) were quickly bouncing

[jira] [Commented] (FLINK-4341) Kinesis connector does not emit maximum watermark properly

[ https://issues.apache.org/jira/browse/FLINK-4341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15426231#comment-15426231 ] Robert Metzger commented on FLINK-4341: --- The reason why the Kinesis consumer is not emitting the

[jira] [Commented] (FLINK-4341) Kinesis connector does not emit maximum watermark properly

[ https://issues.apache.org/jira/browse/FLINK-4341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15426232#comment-15426232 ] Tzu-Li (Gordon) Tai commented on FLINK-4341: I can take a look at fixing this after I get back