[FLINK-27332] org.apache.flink.streaming.api.functions.sink.filesystem.Bucket can't receive completion notification for savepoint

• Type: Bug
• Status: Closed
• Priority: Blocker
• Resolution: Information Provided
• Affects Version/s: 1.15.0
• Component/s: API / DataStream, Connectors / FileSystem
• Assignee: Unassigned
• Reporter: Darcy Lin
• Created: 20/Apr/22 18:02
• Updated: 21/Apr/22 03:00
• Resolved: 21/Apr/22 03:00

Description

2022-04-20 17:28:03,525 INFO  org.apache.flink.streaming.api.functions.sink.filesystem.Buckets [] - Subtask 0 checkpointing for checkpoint with id=225 (max part counter=15).
 
2022-04-20 17:38:06,933 INFO  org.apache.flink.streaming.api.functions.sink.filesystem.Buckets [] - Subtask 0 checkpointing for checkpoint with id=226 (max part counter=15).
2022-04-20 17:38:08,228 INFO  org.apache.flink.streaming.api.functions.sink.filesystem.Buckets [] - Subtask 0 received completion notification for checkpoint with id=226.
 

As shown in the above log, checkpoint 225 is triggered by savepoint, there is no log about "checkpoint completed", and checkpoint 226 is a normal checkpoint and everything works fine. The impact is that savepoint cannot modify pending files into finished.