[
https://issues.apache.org/jira/browse/BEAM-1393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15869767#comment-15869767
]
ASF GitHub Bot commented on BEAM-1393:
--
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/BEAM-1393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15869748#comment-15869748
]
ASF GitHub Bot commented on BEAM-1393:
--
Github user aljoscha closed the pull request a
[
https://issues.apache.org/jira/browse/BEAM-1393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15867524#comment-15867524
]
ASF GitHub Bot commented on BEAM-1393:
--
GitHub user aljoscha opened a pull request:
[
https://issues.apache.org/jira/browse/BEAM-1393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15862325#comment-15862325
]
Jingsong Lee commented on BEAM-1393:
BTW, I think SPLIT_DISTRIBUTE state maybe need a n
[
https://issues.apache.org/jira/browse/BEAM-1393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15862290#comment-15862290
]
Jingsong Lee commented on BEAM-1393:
Totally agree!
{{AbstractStreamOperator}} will che
[
https://issues.apache.org/jira/browse/BEAM-1393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15861079#comment-15861079
]
Aljoscha Krettek commented on BEAM-1393:
Yes, your analysis is spot on!
I think wh
[
https://issues.apache.org/jira/browse/BEAM-1393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15860992#comment-15860992
]
Jingsong Lee commented on BEAM-1393:
Good point! The processing of pushed-back events i
[
https://issues.apache.org/jira/browse/BEAM-1393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15859777#comment-15859777
]
Aljoscha Krettek commented on BEAM-1393:
That last part is actually a bit more comp
[
https://issues.apache.org/jira/browse/BEAM-1393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15859138#comment-15859138
]
Jingsong Lee commented on BEAM-1393:
About point 7, no matter what state we want, we ju
[
https://issues.apache.org/jira/browse/BEAM-1393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15858871#comment-15858871
]
ASF GitHub Bot commented on BEAM-1393:
--
GitHub user JingsongLi opened a pull request:
[
https://issues.apache.org/jira/browse/BEAM-1393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15856453#comment-15856453
]
Jingsong Lee commented on BEAM-1393:
(y)
But there is a problem with the 6 point.
Abs
[
https://issues.apache.org/jira/browse/BEAM-1393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15856294#comment-15856294
]
Aljoscha Krettek commented on BEAM-1393:
Yes, there are definitely some changes tha
[
https://issues.apache.org/jira/browse/BEAM-1393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855649#comment-15855649
]
Jingsong Lee commented on BEAM-1393:
[~aljoscha] I found some APIs changed in Flink 1.2
13 matches
Mail list logo