[jira] [Commented] (FLINK-10327) Pass processWatermark calls from (Co)ProcessOperator to (Co)ProcessFunction

2018-09-17 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16617421#comment-16617421 ] Piotr Nowojski commented on FLINK-10327: I would be also in favour of *won't fixing* but maybe

[jira] [Commented] (FLINK-10327) Pass processWatermark calls from (Co)ProcessOperator to (Co)ProcessFunction

2018-09-17 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16617287#comment-16617287 ] Kostas Kloudas commented on FLINK-10327: [~pnowojski] as you mention, in terms of code, the

[jira] [Commented] (FLINK-10327) Pass processWatermark calls from (Co)ProcessOperator to (Co)ProcessFunction

2018-09-17 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16617218#comment-16617218 ] Piotr Nowojski commented on FLINK-10327: [~kkl0u], my argument in favour of exposing

[jira] [Commented] (FLINK-10327) Pass processWatermark calls from (Co)ProcessOperator to (Co)ProcessFunction

2018-09-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16617201#comment-16617201 ] ASF GitHub Bot commented on FLINK-10327: pnowojski closed pull request #6687:

[jira] [Commented] (FLINK-10327) Pass processWatermark calls from (Co)ProcessOperator to (Co)ProcessFunction

2018-09-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16617200#comment-16617200 ] ASF GitHub Bot commented on FLINK-10327: pnowojski commented on issue #6687:

[jira] [Commented] (FLINK-10327) Pass processWatermark calls from (Co)ProcessOperator to (Co)ProcessFunction

2018-09-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16613537#comment-16613537 ] ASF GitHub Bot commented on FLINK-10327: kl0u commented on issue #6687: [FLINK-10327][streaming]

[jira] [Commented] (FLINK-10327) Pass processWatermark calls from (Co)ProcessOperator to (Co)ProcessFunction

2018-09-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16612390#comment-16612390 ] ASF GitHub Bot commented on FLINK-10327: pnowojski opened a new pull request #6687:

[jira] [Commented] (FLINK-10327) Pass processWatermark calls from (Co)ProcessOperator to (Co)ProcessFunction

2018-09-12 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16612388#comment-16612388 ] Piotr Nowojski commented on FLINK-10327: [~dangdangdang] ops sorry I forgot to assign myself to

[jira] [Commented] (FLINK-10327) Pass processWatermark calls from (Co)ProcessOperator to (Co)ProcessFunction

2018-09-12 Thread Shimin Yang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16612278#comment-16612278 ] Shimin Yang commented on FLINK-10327: - Sounds good, I ll work on it. > Pass processWatermark calls