Yanfei Lei

[FLINK-28626][tests]Fix unstable RescaleCheckpointManuallyITCase

4

## What is the purpose of the change Refactor `RescaleCheckpointManuallyITCase`. ## Brief change log - Modify `NotifyingDefiniteKeySource` to wait for checkpoints to complete. - Make job fail artificially, to retain...

[FLINK-32440][checkpoint] Introduce file merging configurations

2

## What is the purpose of the change Introduce cluster-level file merging related configurations. ## Brief change log - Add `state.checkpoints.file-merging.*` configurations. ## Verifying this change This change is already...

use circleCI build java static

[FLINK-32087][checkpoint] Introduce space amplification statistics of file merging

1

## What is the purpose of the change This PR introduces space amplification statistics of file merging. ## Brief change log - Add `SpaceStat` class in `FileMergingSnapshotManager`. - Update `SpaceStat`...

[FLINK-32082][docs] Documentation of checkpoint file-merging

1

## What is the purpose of the change This PR adds documentation of checkpoint file-merging. ## Brief change log - add documentation of checkpoint file-merging ## Verifying this change This...

[FLINK-35030][runtime] Introduce Epoch Manager under async execution

2

## What is the purpose of the change This PR introduces Epoch Manager to handle watermark and watermark status processing under async execution. Epoch manager segments inputs into distinct epochs,...

[FLINK-35049][state] Implement Map Async State API for ForStStateBackend

1

## What is the purpose of the change This PR implements Map Async State API for ForStStateBackend. ## Brief change log - Introduce `ForStDBIterRequest` and `ForStIterateOperation` for `Map#iterator` - Introduce...

[FLINK-35268][state] Add ttl interface for Async State API && implement TtlListStateV2/TtlValueStateV2

1

## What is the purpose of the change - This PR supports ttl for stateV2, which adds ttl interfaces for Async State API, and implements `TtlListStateV2`/`TtlValueStateV2`/`TtlMapStateV2`/`TtlAggStateV2`/`TtlReducingStateV2`. Note: StateV2 does not...

[FLINK-35029][state/forst] Store timer in JVM heap when use async state backend

2

## What is the purpose of the change This PR supports storing timer in JVM heap when use async state backend. Note: Timers are stored as raw keyed state instead...