[FLINK-26151] inprogressfileRecoverable not be clean up after restoring the bucket

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.15.0
• Fix Version/s: 1.15.0, 1.16.0
• Component/s: FileSystems
• Labels: pull-request-available
• Assignee: WangXiaoyong
• Reporter: WangXiaoyong
• Created: 15/Feb/22 10:09
• Updated: 21/Mar/22 03:22
• Resolved: 21/Mar/22 03:20

Description

In order to clear the previous inProgressFileRecoverable when the checkpoint is successful, inProgressFileRecoverable will be added to inProgressFileRecoverablesPerCheckpoint when the checkpoint is started, but when the bucket is recovered from bucketState, inProgressFileRecoverablesPerCheckpoint does not record inProgressFileRecoverable, resulting in inProgressFileRecoverable not be clean up.

Issue Links

• is related to: FLINK-26755 Cleanup inprogressfileRecoverable for FileSink on restoring
• links to: GitHub Pull Request #18776