Jinzhong Li

[FLINK-28515][checkpoint]Try to clean up localSnapshot files after checkpoint aborted

2

## What is the purpose of the change This pull request fix the problem that files in local recovery directory hasn't be clean up properly after checkpoint abort. ## Brief...

[FLINK-34050][state] Clean up useless files in deleted ranges during rescaling for RocksdbStateBackend

1

## What is the purpose of the change This pull request cleans up useless sst files within rocksdb during rescaling, which reclaims local disk space, reducing the space amplification problem...

[FLINK-35047][state] Shutdown StateExecutors when ForStKeyedStateBackend is disposed

1

## What is the purpose of the change This pull request shuts down the ForStStateExecutors when ForStKeyedStateBackend is disposed. ## Brief change log - Shutdown the StateExecutors in ForStKeyedStateBackend. ##...

[FLINK-35897][Checkpoint] Cleanup completed resource when checkpoint is canceled

1

## What is the purpose of the change This pull request cleanup completed checkpoint resource when the job checkpoint is canceled. ## Brief change log - When the asynchronous snapshot...