[jira] [Commented] (FLINK-2646) Rich functions should provide a method "closeAfterFailure()"

2017-09-14 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16166387#comment-16166387 ] Aljoscha Krettek commented on FLINK-2646: - I thought about this and the new

[jira] [Commented] (FLINK-2646) Rich functions should provide a method "closeAfterFailure()"

2016-11-23 Thread Liang Chen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15691858#comment-15691858 ] Liang Chen commented on FLINK-2646: --- Please go ahead, thanks. Sorry, i am a little busy recently. >

[jira] [Commented] (FLINK-2646) Rich functions should provide a method "closeAfterFailure()"

2016-11-23 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15689779#comment-15689779 ] Stephan Ewen commented on FLINK-2646: - [~kkl0u] Please go ahead! > Rich functions should provide a

[jira] [Commented] (FLINK-2646) Rich functions should provide a method "closeAfterFailure()"

2016-11-23 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15689706#comment-15689706 ] Kostas Kloudas commented on FLINK-2646: --- Can I take the issue? It seems inactive for the last year

[jira] [Commented] (FLINK-2646) Rich functions should provide a method "closeAfterFailure()"

2016-11-21 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15683181#comment-15683181 ] Stephan Ewen commented on FLINK-2646: - Strictly speaking, this is API breaking, because we add a

[jira] [Commented] (FLINK-2646) Rich functions should provide a method "closeAfterFailure()"

2016-11-19 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15679122#comment-15679122 ] Chesnay Schepler commented on FLINK-2646: - could you post how you defined the method? > Rich

[jira] [Commented] (FLINK-2646) Rich functions should provide a method "closeAfterFailure()"

2016-11-19 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15679034#comment-15679034 ] Kostas Kloudas commented on FLINK-2646: --- By the way the {{RichFunction}} is annotated as {{Public}}

[jira] [Commented] (FLINK-2646) Rich functions should provide a method "closeAfterFailure()"

2016-11-16 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15673034#comment-15673034 ] Kostas Kloudas commented on FLINK-2646: --- Yes I agree. This is what I also meant in my comment above.

[jira] [Commented] (FLINK-2646) Rich functions should provide a method "closeAfterFailure()"

2016-11-16 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15673030#comment-15673030 ] Kostas Kloudas commented on FLINK-2646: --- Yes, I think we are on the same page. This is what I also

[jira] [Commented] (FLINK-2646) Rich functions should provide a method "closeAfterFailure()"

2016-11-16 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15670219#comment-15670219 ] Stephan Ewen commented on FLINK-2646: - One thing we can do is mirror the way it is done on the

[jira] [Commented] (FLINK-2646) Rich functions should provide a method "closeAfterFailure()"

2016-11-16 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15670070#comment-15670070 ] Kostas Kloudas commented on FLINK-2646: --- Big +1 for the feature as well. To revive the discussion,

[jira] [Commented] (FLINK-2646) Rich functions should provide a method "closeAfterFailure()"

2015-11-19 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15013528#comment-15013528 ] Robert Metzger commented on FLINK-2646: --- Big +1 for this feature! > Rich functions should provide a

[jira] [Commented] (FLINK-2646) Rich functions should provide a method "closeAfterFailure()"

2015-11-19 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15013589#comment-15013589 ] Stephan Ewen commented on FLINK-2646: - Sorry, overlooked this question: 1) The runtime operators know

[jira] [Commented] (FLINK-2646) Rich functions should provide a method "closeAfterFailure()"

2015-09-13 Thread chenliang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14742379#comment-14742379 ] chenliang commented on FLINK-2646: -- 1.Can you help me to quickly understand "The runtime is the changed