flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Márton Balassi (JIRA) <j...@apache.org>
Subject [jira] [Resolved] (FLINK-1625) Add cancel method to user defined sources and sinks and call them on task cancellation
Date Wed, 04 Mar 2015 22:10:39 GMT

     [ https://issues.apache.org/jira/browse/FLINK-1625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

Márton Balassi resolved FLINK-1625.
-----------------------------------
    Resolution: Implemented

Implemented via 3abd6c8, 8436e9c and 08ef02e.

> 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
>
> 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)

Mime
View raw message