[
https://issues.apache.org/jira/browse/FLINK-1625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-1625:
----------------------------------
Fix Version/s: 0.9
> 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
> Assignee: Gyula Fora
> Fix For: 0.9
>
>
> 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)
