Bulk Operation

FLINK-25842 Test Changelog StateBackend V2 Manually

FLINK-25842 move “enablechangelog” constant out of flink-streaming-java module

FLINK-25842 Show the delegated StateBackend and whether changelog is enabled in the UI

FLINK-25842 Scatter dstl files into separate directories by job id

FLINK-25842 Expose changelog configuration in RestAPI and WebUI

FLINK-25842 Reduce multiple reads to the same Changelog file in the same taskmanager during restore

FLINK-25842 Restoring from non-changelog checkpoint with changelog state-backend enabled in CLAIM mode discards state in use

FLINK-25842 [ZH] Add ChangelogBackend documentation

FLINK-25842 Pre-emptively uploaded changelog not discarded up if materialized before checkpoint

FLINK-25842 Add/Expose/Differentiate metrics of checkpoint size between changelog size vs materialization size

FLINK-25842 Support local recovery

FLINK-25842 Add benchmarks for the ChangelogStateBackend

FLINK-25842 State ownership: Consider disallowing in-memory state handles for materialized state

FLINK-25842 State ownership: track and discard private state (materialized: rocks, heap)

FLINK-25842 State ownership: prevent shared state deletion on TM

FLINK-25842 State ownership: compute shared state on recovery

FLINK-25842 Support recovery (from checkpoints) after disabling changelog backend

FLINK-25842 State ownership: Support more than one retained checkpoints

FLINK-25842 Support state migration

FLINK-25842 State ownership: track and discard private state (registry+changelog)

FLINK-25842 State ownership: prevent private state deletion on JM