[jira] [Commented] (BEAM-1641) Support synchronized processing time in Flink runner

2017-05-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15993516#comment-15993516 ] ASF GitHub Bot commented on BEAM-1641: -- Github user asfgit closed the pull request at:

[jira] [Commented] (BEAM-1641) Support synchronized processing time in Flink runner

2017-05-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15993159#comment-15993159 ] ASF GitHub Bot commented on BEAM-1641: -- GitHub user kennknowles opened a pull request:

[jira] [Commented] (BEAM-1641) Support synchronized processing time in Flink runner

2017-05-01 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15992110#comment-15992110 ] Jingsong Lee commented on BEAM-1641: There are some differences between the processing of event time

[jira] [Commented] (BEAM-1641) Support synchronized processing time in Flink runner

2017-04-28 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15988973#comment-15988973 ] Aljoscha Krettek commented on BEAM-1641: Quick side note: In Flink, if you set your "stream time

[jira] [Commented] (BEAM-1641) Support synchronized processing time in Flink runner

2017-04-28 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15988696#comment-15988696 ] Aljoscha Krettek commented on BEAM-1641: Yes, as Kenn said, we should probably replace synchronised

[jira] [Commented] (BEAM-1641) Support synchronized processing time in Flink runner

2017-04-28 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15988363#comment-15988363 ] Jingsong Lee commented on BEAM-1641: I think it is difficult to achieve, it requires Flink-runtime

[jira] [Commented] (BEAM-1641) Support synchronized processing time in Flink runner

2017-03-22 Thread Kenneth Knowles (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15937688#comment-15937688 ] Kenneth Knowles commented on BEAM-1641: --- Since this means that processing time triggers cannot work

[jira] [Commented] (BEAM-1641) Support synchronized processing time in Flink runner

2017-03-09 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15902802#comment-15902802 ] Aljoscha Krettek commented on BEAM-1641: Wow, that's a tough one. I think we might first have to