Stephan Ewen created FLINK-1763:
-----------------------------------
Summary: 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
(v6.3.4#6332)
