Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-19698

Add close() method and onCheckpointComplete() to the Source.

    XMLWordPrintableJSON

    Details

      Description

      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.

      1. 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.
      2. 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.

       

       

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                becket_qin Jiangjie Qin
                Reporter:
                becket_qin Jiangjie Qin
              • Votes:
                0 Vote for this issue
                Watchers:
                5 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: