[
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]
[
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]
[
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:
[
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:
[
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:
[
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:
[
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:
[
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:
[
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:
[
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:
[
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:
[
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:
[
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:
[
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:
[
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]
[
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]
[
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]
[
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]
[
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]
[
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]
[
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]
[
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]
[
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]
[
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:
[
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:
[
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
[
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
[
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
[
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
29 matches
Mail list logo