zhang-arvin opened a new pull request, #9535: URL: https://github.com/apache/paimon/pull/9535
Fixes #9533: When Flink Dedicated Streaming Compact Job restores from a checkpoint whose snapshot has been expired, the job gets stuck in a loop because nextPlan() keeps returning SnapshotNotExistPlan without incrementing nextSnapshotId. ### Fix In restore(), when nextSnapshotId is less than earliestSnapshotId (snapshot expired), set nextSnapshotId to null so plan() falls back to tryFirstPlan() which uses ContinuousCompactorStartingScanner to find the latest compact snapshot. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
