[jira] [Commented] (FLINK-13798) Refactor the process of checking stream status while emitting watermark in source

[ https://issues.apache.org/jira/browse/FLINK-13798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16914044#comment-16914044 ] zhijiang commented on FLINK-13798: -- After further researching on this issue, it seems not feasible to

[jira] [Commented] (FLINK-13798) Refactor the process of checking stream status while emitting watermark in source

[ https://issues.apache.org/jira/browse/FLINK-13798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16911537#comment-16911537 ] zhijiang commented on FLINK-13798: -- Thanks for this notification [~StephanEwen]. Wish it would make the

[jira] [Commented] (FLINK-13798) Refactor the process of checking stream status while emitting watermark in source

[ https://issues.apache.org/jira/browse/FLINK-13798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16911455#comment-16911455 ] zhijiang commented on FLINK-13798: -- Thanks for the replies. [~StephanEwen] Wish it would make logic

[jira] [Commented] (FLINK-13798) Refactor the process of checking stream status while emitting watermark in source

[ https://issues.apache.org/jira/browse/FLINK-13798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16911428#comment-16911428 ] Stephan Ewen commented on FLINK-13798: -- FYI: I believe one outcome of FLIP-27 will be to drop the

[jira] [Commented] (FLINK-13798) Refactor the process of checking stream status while emitting watermark in source

[ https://issues.apache.org/jira/browse/FLINK-13798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16911275#comment-16911275 ] zhijiang commented on FLINK-13798: -- Thanks for the offline discussion and suggestion.  [~pnowojski]