[jira] [Created] (FLINK-1625) Add cancel method to user defined sources and sinks and call them on task cancellation

["Gyula Fora (JIRA)" <ji...@apache.org>]

Gyula Fora created FLINK-1625:
---------------------------------

             Summary: Add cancel method to user defined sources and sinks and call them on task cancellation
                 Key: FLINK-1625
                 URL: https://issues.apache.org/jira/browse/FLINK-1625
             Project: Flink
          Issue Type: Improvement
          Components: Streaming
            Reporter: Gyula Fora


Currently on task cancellation the user defined functions get interrupted without notice. This can cause serious problems for functions that have established connection with the outside world, for instance message queue connectors, file sources etc.

An explicit cancel() method should be added to the SourceFunction and SinkFunction interfaces so that the user would be forced to implement the cancel functionality which is necessary for the specific udf.

The cancel() method in the StreamVertex should also be implemented in a way that it calls the cancel methods of the Sink and Source functions on cancellation.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)