Yanfei Lei comments

Results 29 comments of


                                            Yanfei Lei

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

Thanks all for the detailed review! 🚀🚀

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

> Thanks for the update! Overall LGTM. And will this `SpaceStat` report to metrics? Currently no, will report to metric in FLINK-32091.

[FLINK-35253][docs-zh]Translate "State Processor API "page into Chinese

Hi @drymatini, thanks for your contribution, "State Processor API" was already translated in master, I think documents do not need to be backported to the historical release branch, maybe we...

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

@flinkbot run azure

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

@flinkbot run azure

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

Thanks for the detailed review🚀, merged

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

> I'd suggest split the two `InternalTimeServiceManager` in `StreamOperatorStateContext`, since there still a chance that we use state backend like ForSt in sync mode, the `InternalTimeServiceManager` should be the one...

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

@flinkbot run azure

[FLINK-34510][Runtime/State]Rename RestoreMode to RecoveryClaimMode

> @fredia Will need `StateBackend#supportsNoClaimRestoreMode` method name changed to `supportsNoRecoveryClaimMode`? Thanks for the update, both are fine for me since `StateBackend#supportsNoClaimRestoreMode` returns a boolean value.