[flink] Decouple Committer.Context from operator-only assumptions#8221

Merged

JingsongLi merged 5 commits into

apache:masterfrom

ifndef-SleePy:coordinator-commit-pr1-state-store-refactor

Jun 23, 2026

Commits on May 29, 2026

[flink] Introduce StateStore abstraction for committer state access
liubiao.leo
committed

Commits on Jun 12, 2026

[flink] Route Committer.Context state access through StateStore
liubiao.leo
committed
[flink] Decouple CommittableStateManager from Flink state context
liubiao.leo
committed
[flink] Move listener-state snapshot into StoreCommitter.snapshotState
liubiao.leo
committed
[flink] Allow MetricGroup beyond OperatorMetricGroup in Committer.Context
liubiao.leo
committed