[jira] [Commented] (FLINK-7245) Enhance the operators to support holding back watermarks

[ https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16146023#comment-16146023 ] ASF GitHub Bot commented on FLINK-7245: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-7245) Enhance the operators to support holding back watermarks

[ https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16145199#comment-16145199 ] ASF GitHub Bot commented on FLINK-7245: --- Github user xccui commented on the issue:

[jira] [Commented] (FLINK-7245) Enhance the operators to support holding back watermarks

[ https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16145165#comment-16145165 ] ASF GitHub Bot commented on FLINK-7245: --- Github user fhueske commented on the issue:

[jira] [Commented] (FLINK-7245) Enhance the operators to support holding back watermarks

[ https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16133027#comment-16133027 ] ASF GitHub Bot commented on FLINK-7245: --- Github user xccui commented on the issue:

[jira] [Commented] (FLINK-7245) Enhance the operators to support holding back watermarks

[ https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16132174#comment-16132174 ] ASF GitHub Bot commented on FLINK-7245: --- Github user aljoscha commented on the issue:

[jira] [Commented] (FLINK-7245) Enhance the operators to support holding back watermarks

[ https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16131812#comment-16131812 ] ASF GitHub Bot commented on FLINK-7245: --- Github user fhueske commented on the issue:

[jira] [Commented] (FLINK-7245) Enhance the operators to support holding back watermarks

[ https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16131587#comment-16131587 ] ASF GitHub Bot commented on FLINK-7245: --- Github user xccui commented on the issue:

[jira] [Commented] (FLINK-7245) Enhance the operators to support holding back watermarks

[ https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16131401#comment-16131401 ] ASF GitHub Bot commented on FLINK-7245: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-7245) Enhance the operators to support holding back watermarks

[ https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16131403#comment-16131403 ] ASF GitHub Bot commented on FLINK-7245: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-7245) Enhance the operators to support holding back watermarks

[ https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16131402#comment-16131402 ] ASF GitHub Bot commented on FLINK-7245: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-7245) Enhance the operators to support holding back watermarks

[ https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16131400#comment-16131400 ] ASF GitHub Bot commented on FLINK-7245: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-7245) Enhance the operators to support holding back watermarks

[ https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16128222#comment-16128222 ] ASF GitHub Bot commented on FLINK-7245: --- Github user wuchong commented on the issue:

[jira] [Commented] (FLINK-7245) Enhance the operators to support holding back watermarks

[ https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16126742#comment-16126742 ] ASF GitHub Bot commented on FLINK-7245: --- Github user xccui commented on the issue:

[jira] [Commented] (FLINK-7245) Enhance the operators to support holding back watermarks

[ https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16126307#comment-16126307 ] ASF GitHub Bot commented on FLINK-7245: --- Github user fhueske commented on the issue:

[jira] [Commented] (FLINK-7245) Enhance the operators to support holding back watermarks

[ https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16125422#comment-16125422 ] ASF GitHub Bot commented on FLINK-7245: --- Github user xccui commented on the issue:

[jira] [Commented] (FLINK-7245) Enhance the operators to support holding back watermarks

[ https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16125393#comment-16125393 ] ASF GitHub Bot commented on FLINK-7245: --- Github user aljoscha commented on the issue:

[jira] [Commented] (FLINK-7245) Enhance the operators to support holding back watermarks

[ https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16123696#comment-16123696 ] ASF GitHub Bot commented on FLINK-7245: --- GitHub user xccui opened a pull request:

[jira] [Commented] (FLINK-7245) Enhance the operators to support holding back watermarks

[ https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16123328#comment-16123328 ] Xingcan Cui commented on FLINK-7245: Hi [~fhueske], thanks for the response. I think you are right.

[jira] [Commented] (FLINK-7245) Enhance the operators to support holding back watermarks

[ https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16123314#comment-16123314 ] Fabian Hueske commented on FLINK-7245: -- Hi [~xccui], thanks for the pointer to you code. I had a look

[jira] [Commented] (FLINK-7245) Enhance the operators to support holding back watermarks

[ https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16121855#comment-16121855 ] Xingcan Cui commented on FLINK-7245: Hi [~fhueske], I've got some new ideas about the

[jira] [Commented] (FLINK-7245) Enhance the operators to support holding back watermarks

[ https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16120145#comment-16120145 ] Xingcan Cui commented on FLINK-7245: I have made some minor changes, which can be found at

[jira] [Commented] (FLINK-7245) Enhance the operators to support holding back watermarks

[ https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16118649#comment-16118649 ] Aljoscha Krettek commented on FLINK-7245: - Right now, this sounds more like an implementation

[jira] [Commented] (FLINK-7245) Enhance the operators to support holding back watermarks

[ https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16118503#comment-16118503 ] Fabian Hueske commented on FLINK-7245: -- Great that we are on the same page! Let's see if we want to

[jira] [Commented] (FLINK-7245) Enhance the operators to support holding back watermarks

[ https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16118491#comment-16118491 ] Xingcan Cui commented on FLINK-7245: Thanks for your responses, [~fhueske]. Actually, we were thinking

[jira] [Commented] (FLINK-7245) Enhance the operators to support holding back watermarks

[ https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16116601#comment-16116601 ] Fabian Hueske commented on FLINK-7245: -- Hi [~xccui], I think this is a very good observation: bq.

[jira] [Commented] (FLINK-7245) Enhance the operators to support holding back watermarks

[ https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16115441#comment-16115441 ] Xingcan Cui commented on FLINK-7245: Hi [~fhueske], thanks for your responses. They are really

[jira] [Commented] (FLINK-7245) Enhance the operators to support holding back watermarks

[ https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16114952#comment-16114952 ] Fabian Hueske commented on FLINK-7245: -- Thanks a lot for looking into this [~xccui]! A few comments:

[jira] [Commented] (FLINK-7245) Enhance the operators to support holding back watermarks

[ https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16114167#comment-16114167 ] Xingcan Cui commented on FLINK-7245: Hi all, I'd like to throw out some basic ideas about the design.

[jira] [Commented] (FLINK-7245) Enhance the operators to support holding back watermarks

[ https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16106399#comment-16106399 ] Xingcan Cui commented on FLINK-7245: Thanks for the answer and the suggestion, [~fhueske]. I'll keep

[jira] [Commented] (FLINK-7245) Enhance the operators to support holding back watermarks

[ https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16106397#comment-16106397 ] Fabian Hueske commented on FLINK-7245: -- Hi [~xccui], thanks for the questions. I think you got it

[jira] [Commented] (FLINK-7245) Enhance the operators to support holding back watermarks

[ https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16103282#comment-16103282 ] Xingcan Cui commented on FLINK-7245: Hi [~fhueske], it took me a little time to comprehend how the

[jira] [Commented] (FLINK-7245) Enhance the operators to support holding back watermarks

[ https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16101562#comment-16101562 ] Fabian Hueske commented on FLINK-7245: -- Great, thanks for the response [~xccui]! Ad 2) No, not

[jira] [Commented] (FLINK-7245) Enhance the operators to support holding back watermarks

[ https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16100161#comment-16100161 ] Xingcan Cui commented on FLINK-7245: Thanks, [~fhueske]. The ideas are quite helpful. I'd like to put

[jira] [Commented] (FLINK-7245) Enhance the operators to support holding back watermarks

[ https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16099844#comment-16099844 ] Fabian Hueske commented on FLINK-7245: -- Hi [~xccui], just throwing in some of the ideas I had so far.

[jira] [Commented] (FLINK-7245) Enhance the operators to support holding back watermarks

[ https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16099299#comment-16099299 ] Xingcan Cui commented on FLINK-7245: Sure. I'll draw up a design document for that, as well as for

[jira] [Commented] (FLINK-7245) Enhance the operators to support holding back watermarks

[ https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16098273#comment-16098273 ] Aljoscha Krettek commented on FLINK-7245: - This is an interesting new feature and I've actually