Jiangjie Qin created FLINK-19698:
------------------------------------
Summary: Add close() method and onCheckpointComplete() to the
Source.
Key: FLINK-19698
URL: https://issues.apache.org/jira/browse/FLINK-19698
Project: Flink
Issue Type: Improvement
Components: Connectors / Common
Affects Versions: 1.11.2
Reporter: Jiangjie Qin
Right now there are some caveats to the new Source API. From the implementation
of some connectors. We would like to make the following improvements to the
current Source API.
# Add the following method to the {{SplitReader}} API.
{{public void close() throws Exception；}}
This method allows the SplitReader implementations to be closed properly when
the split fetcher exits.
# Add the following method to the {{SourceReader}} API.
{{public void checkpointComplete(long checkpointId);}}
This method allows the {{SourceReader}} to take some cleanup / reporting
actions when a checkpoint has been successfully taken.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
