WangXiaoyong created FLINK-26151: ------------------------------------ Summary: inprogressfileRecoverable not be clean up after restoring the bucket Key: FLINK-26151 URL: https://issues.apache.org/jira/browse/FLINK-26151 Project: Flink Issue Type: Bug Components: FileSystems Affects Versions: 1.15.0 Reporter: WangXiaoyong Fix For: 1.15.0
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. -- This message was sent by Atlassian Jira (v8.20.1#820001)