ifndef-SleePy opened a new pull request, #8221: URL: https://github.com/apache/paimon/pull/8221
## Purpose Tracked under: #8220 Remove the assumption that `Committer` always runs inside a Flink operator, so the same committer logic can be hosted by either an operator or a `OperatorCoordinator` (introduced in a follow-up PR under #8220 ). This PR is a **pure refactor** — no behavior change. ### Changes - Introduce a `StateStore` abstraction for committer state access, with operator-backed and memory-backed implementations. - Route `Committer.Context` state access through `StateStore`; decouple `CommittableStateManager` from Flink's state initialization context. - Move the listener-state snapshot into `StoreCommitter.snapshotState`, so the committer owns its state lifecycle end-to-end. - Relax the metric group exposed via `Committer.Context` so it is not tied to `OperatorMetricGroup`, and adapt `CommitterMetrics` accordingly. ### Tests Existing committer / sink unit tests pass unchanged. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
