[ https://issues.apache.org/jira/browse/FLINK-2647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Stephan Ewen closed FLINK-2647. ------------------------------- > Stream operators need to differentiate between close() and dispose() > -------------------------------------------------------------------- > > Key: FLINK-2647 > URL: https://issues.apache.org/jira/browse/FLINK-2647 > Project: Flink > Issue Type: Bug > Components: Streaming > Affects Versions: 0.10 > Reporter: Stephan Ewen > Assignee: Stephan Ewen > Fix For: 0.10 > > > Currently, operators make no distinction between closing (which needs to emit > remaining buffered data) and disposing (releasing resources). > In case of a failure, we want to only release the resources, and not attempt > to send pending buffered data. > Effectively, streaming operators need to implement these methods then: > - open() > - processRecord() > - processWatermark() > - close() > - dispose() -- This message was sent by Atlassian JIRA (v6.3.4#6332)