[FLINK-29856] Triggering savepoint does not trigger operator notifyCheckpointComplete

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Not A Bug
• Affects Version/s: 1.15.0, 1.16.0
• Component/s: Runtime / Checkpointing
• Assignee: Unassigned
• Reporter: Mason Chen
• Created: 03/Nov/22 02:49
• Updated: 08/Feb/23 14:53
• Resolved: 08/Feb/23 14:53

Description

When I trigger a savepoint with the Flink K8s operator, I verified for two sources (KafkaSource and MultiClusterKafkaSource) do not invoke notifyCheckpointComplete. This is easily reproducible in a simple pipeline (e.g. KafkaSource -> print). In this case, the savepoint is complete and successful, which is verified by the Flink Checkpoint UI tab and the jobmanager logs. e.g. `
Triggering checkpoint 3 (type=SavepointType{name='Savepoint', postCheckpointAction=NONE, formatType=CANONICAL})`
 

However, when the checkpoint occurs via the interval, I do see the sources checkpointing properly and expected logs in the output.

After the ticket was initially filed, I also checked with other stateful UDFs and observed the same behavior.

Issue Links

• is related to: FLINK-25191 Skip savepoints for recovery