[FLINK-22133] SplitEmumerator does not provide checkpoint id in snapshot

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.12.0
• Fix Version/s: 1.13.0
• Component/s: Connectors / Common
• Labels: pull-request-available
• 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.
• Assignee: Stephan Ewen
• Reporter: Brian Zhou
• Created: 07/Apr/21 08:29
• Updated: 28/Aug/21 11:16
• Resolved: 20/Apr/21 16:18

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

Issue Links

• links to: GitHub Pull Request #15677