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

2018-11-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16694736#comment-16694736 ] ASF GitHub Bot commented on FLINK-5697: --- tweise commented on issue #6980: [FLINK-5697] [kinesis]

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

2018-11-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16694552#comment-16694552 ] ASF GitHub Bot commented on FLINK-5697: --- asfgit closed pull request #6980: [FLINK-5697] [kinesis]

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

2018-11-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16693743#comment-16693743 ] ASF GitHub Bot commented on FLINK-5697: --- tweise commented on a change in pull request #6980:

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

2018-11-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16693734#comment-16693734 ] ASF GitHub Bot commented on FLINK-5697: --- tweise commented on a change in pull request #6980:

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

2018-11-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16693731#comment-16693731 ] ASF GitHub Bot commented on FLINK-5697: --- tweise commented on a change in pull request #6980:

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

2018-11-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16693518#comment-16693518 ] ASF GitHub Bot commented on FLINK-5697: --- mxm commented on a change in pull request #6980:

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

2018-11-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16693521#comment-16693521 ] ASF GitHub Bot commented on FLINK-5697: --- mxm commented on a change in pull request #6980:

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

2018-11-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16693523#comment-16693523 ] ASF GitHub Bot commented on FLINK-5697: --- mxm commented on a change in pull request #6980:

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

2018-11-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16693520#comment-16693520 ] ASF GitHub Bot commented on FLINK-5697: --- mxm commented on a change in pull request #6980:

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

2018-11-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16693519#comment-16693519 ] ASF GitHub Bot commented on FLINK-5697: --- mxm commented on a change in pull request #6980:

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

2018-11-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16693522#comment-16693522 ] ASF GitHub Bot commented on FLINK-5697: --- mxm commented on a change in pull request #6980:

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

2018-11-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16693524#comment-16693524 ] ASF GitHub Bot commented on FLINK-5697: --- mxm commented on a change in pull request #6980:

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

2018-11-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16693517#comment-16693517 ] ASF GitHub Bot commented on FLINK-5697: --- mxm commented on a change in pull request #6980:

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

2018-11-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16693525#comment-16693525 ] ASF GitHub Bot commented on FLINK-5697: --- mxm commented on a change in pull request #6980:

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

2018-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676177#comment-16676177 ] ASF GitHub Bot commented on FLINK-5697: --- tzulitai commented on issue #6980: [FLINK-5697] [kinesis]

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

2018-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676173#comment-16676173 ] ASF GitHub Bot commented on FLINK-5697: --- tweise commented on issue #6980: [FLINK-5697] [kinesis]

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

2018-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16675628#comment-16675628 ] ASF GitHub Bot commented on FLINK-5697: --- jgrier commented on issue #6980: [FLINK-5697] [kinesis]

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

2018-11-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16672295#comment-16672295 ] ASF GitHub Bot commented on FLINK-5697: --- tweise commented on issue #6980: [FLINK-5697] [kinesis]

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

2018-11-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16672285#comment-16672285 ] ASF GitHub Bot commented on FLINK-5697: --- EronWright commented on issue #6980: [FLINK-5697]

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

2018-11-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16672248#comment-16672248 ] ASF GitHub Bot commented on FLINK-5697: --- tweise closed pull request #6980: [FLINK-5697] [kinesis]

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

2018-11-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16672249#comment-16672249 ] ASF GitHub Bot commented on FLINK-5697: --- tweise opened a new pull request #6980: [FLINK-5697]

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

2018-11-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16671151#comment-16671151 ] ASF GitHub Bot commented on FLINK-5697: --- tweise commented on issue #6980: [FLINK-5697] [kinesis]

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

2018-11-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16671149#comment-16671149 ] ASF GitHub Bot commented on FLINK-5697: --- tweise opened a new pull request #6980: [FLINK-5697]

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

2018-10-30 Thread Thomas Weise (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16669566#comment-16669566 ] Thomas Weise commented on FLINK-5697: - The latest related discussion:

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

2018-03-07 Thread Thomas Weise (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16390365#comment-16390365 ] Thomas Weise commented on FLINK-5697: - For idleness detection see:

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

2018-02-27 Thread Thomas Weise (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16379815#comment-16379815 ] Thomas Weise commented on FLINK-5697: - We have implemented periodic watermark support in a

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

2018-02-08 Thread Thomas Weise (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16357640#comment-16357640 ] Thomas Weise commented on FLINK-5697: - Since shards are immutable wrt their hash key range and records

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

2017-04-17 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15970738#comment-15970738 ] Tzu-Li (Gordon) Tai commented on FLINK-5697: I'd say it still makes sense. If I understand how

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

2017-04-15 Thread Eron Wright (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15970149#comment-15970149 ] Eron Wright commented on FLINK-5697: - My understanding is that per-partition watermarks make sense