Zakelly

[DRAFT][FLINK-34516] Move CheckpointingMode to flink-core

1

## Do not merge this for now ## What is the purpose of the change In FLIP-406, we want to merge all options in `ExecutionCheckpointingOptions` to `CheckpointingOptions`, which depends on...

[FLINK-34454] Introduce StateRecoveryOptions in flink-core and Rename options

3

## What is the purpose of the change As one part of FLIP-406, This PR introduce the `StateRecoveryOptions` in flink-core, and move & rename all state-recovery-related options into. ## Brief...

[FLINK-34495][e2e] Enable incremental checkpoint for stop-with-savepoint tests

1

## What is the purpose of the change Fix the unstable e2e tests related with stop-with-savepoint. See FLINK-34495. ## Brief change log - Enable incremental cp for rocksdb in related...

[FLINK-32075][FLIP-306][Checkpoint] Delete merged files on checkpoint abort or subsumption

7

## What is the purpose of the change As important part of the FLIP-306, this PR enables the file deletion on checkpoint abort or subsumption. ## Brief change log -...

Memory issue of kvrocks2redis detected by ASan/TSan

12

### Search before asking - [X] I had searched in the [issues](https://github.com/apache/kvrocks/issues) and found no similar issues. ### Motivation Currently, the Kvrocks2redis CI fails with TSAN/ASAN or in macos env....

[DRAFT] Declare async state processing

1

## this is only a draft, do not merge this ## This is the draft of declaring processing interface introduced in FLIP-455 https://cwiki.apache.org/confluence/x/C4owEg

[DRAFT][FLINK-35186][Runtime/State] Create State V2 from new StateDescriptor

1

## This is only a draft for testing purpose, do not merge this ## What is the purpose of the change *(For example: This pull request makes task deployment go...

[FLINK-35356][State] State descriptor and implementation for async reducing state

1

## What is the purpose of the change This PR provides the definition of `StateDescriptor` and simple implementation for `ReducingState` in `State V2`. ## Brief change log - Definition and...

[FLINK-35412][State/Runtime] Batch execution of async state request callback

2

## What is the purpose of the change Currently, when there is a state request finished, a callback will be wrapped into a mail and inserted into the `Mailbox`. This...

[FLINK-36119] Conditionally interfaces for StateFuture

1

## What is the purpose of the change As described in FLIP-455, this PR provides some interface for conditional branchings under `StateFuture` ## Brief change log - Add interface in...