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)
