[jira] [Commented] (BEAM-1393) Update Flink Runner to Flink 1.2.0

2017-02-16 Thread ASF GitHub Bot (JIRA)
[ 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:

[jira] [Commented] (BEAM-1393) Update Flink Runner to Flink 1.2.0

2017-02-16 Thread ASF GitHub Bot (JIRA)
[ 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

[jira] [Commented] (BEAM-1393) Update Flink Runner to Flink 1.2.0

2017-02-15 Thread ASF GitHub Bot (JIRA)
[ 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:

[jira] [Commented] (BEAM-1393) Update Flink Runner to Flink 1.2.0

2017-02-11 Thread Jingsong Lee (JIRA)
[ 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

[jira] [Commented] (BEAM-1393) Update Flink Runner to Flink 1.2.0

2017-02-10 Thread Jingsong Lee (JIRA)
[ 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

[jira] [Commented] (BEAM-1393) Update Flink Runner to Flink 1.2.0

2017-02-10 Thread Aljoscha Krettek (JIRA)
[ 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

[jira] [Commented] (BEAM-1393) Update Flink Runner to Flink 1.2.0

2017-02-10 Thread Jingsong Lee (JIRA)
[ 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

[jira] [Commented] (BEAM-1393) Update Flink Runner to Flink 1.2.0

2017-02-09 Thread Aljoscha Krettek (JIRA)
[ 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

[jira] [Commented] (BEAM-1393) Update Flink Runner to Flink 1.2.0

2017-02-08 Thread Jingsong Lee (JIRA)
[ 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

[jira] [Commented] (BEAM-1393) Update Flink Runner to Flink 1.2.0

2017-02-08 Thread ASF GitHub Bot (JIRA)
[ 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:

[jira] [Commented] (BEAM-1393) Update Flink Runner to Flink 1.2.0

2017-02-07 Thread Jingsong Lee (JIRA)
[ 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

[jira] [Commented] (BEAM-1393) Update Flink Runner to Flink 1.2.0

2017-02-07 Thread Aljoscha Krettek (JIRA)
[ 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

[jira] [Commented] (BEAM-1393) Update Flink Runner to Flink 1.2.0

2017-02-07 Thread Jingsong Lee (JIRA)
[ 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