flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Stephan Ewen (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-1763) Remove "cancel" from streaming SinkFunction
Date Sat, 21 Mar 2015 19:00:38 GMT

    [ https://issues.apache.org/jira/browse/FLINK-1763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14372961#comment-14372961

Stephan Ewen commented on FLINK-1763:

The Batch API calles the {{close()}} function also in the cancelling case. This makes many
implementations easy. Cancelling is to the sing function just like closing (early).

> Remove "cancel" from streaming SinkFunction
> -------------------------------------------
>                 Key: FLINK-1763
>                 URL: https://issues.apache.org/jira/browse/FLINK-1763
>             Project: Flink
>          Issue Type: Improvement
>          Components: Streaming
>    Affects Versions: 0.9
>            Reporter: Stephan Ewen
>             Fix For: 0.9
> Since the streaming sink function is called individually for each record, it does not
require a {{cancel()}} function. The system can cancel between calls to that function (which
it cannot do for the source function).
> Removing this method removes the need to always implement the unnecessary, and usually
empty, method.

This message was sent by Atlassian JIRA

View raw message