[jira] [Created] (FLINK-19698) Add close() method and onCheckpointComplete() to the Source.

[Shang Yuanchun (Jira)]

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)