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

SplitEmumerator does not provide checkpoint id in snapshot

    XMLWordPrintableJSON

    Details

    • Release Note:
      The unified source API for connectors has a minor breaking change: The {{SplitEnumerator.snapshotState()}} method was adjusted to accept the Checkpoint ID of the checkpoint for which the snapshot is created.

      Description

      In ExternallyInducedSource API, the checkpoint trigger exposes the checkpoint Id for the external client to identify the checkpoint. However, in the FLIP-27 source, the SplitEmumerator::snapshot() is a no-arg method. The connector cannot track the checkpoint ID from Flink

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                sewen Stephan Ewen
                Reporter:
                Brian Zhou Brian Zhou
              • Votes:
                0 Vote for this issue
                Watchers:
                5 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: