weiqingy opened a new issue, #646: URL: https://github.com/apache/flink-agents/issues/646
### Search before asking - [x] I searched in the [issues](https://github.com/apache/flink-agents/issues) and found nothing similar. ### Description ## Summary PR #546 introduced 5 focused manager classes by decomposing `ActionExecutionOperator`. Minimal contract tests (4 files, 7 tests) were added to keep that PR reviewable. Heavier coverage was explicitly deferred and is tracked here. ## Deferred Coverage | Manager | Missing Coverage | |---------|-----------------| | `OperatorStateManager` | Flink-harness-based tests (real `StateInitializationContext`, keyed state, operator state backend) | | `DurableExecutionManager` | Full snapshot + recovery cycle; `notifyCheckpointComplete` pruning behaviour | | `EventRouter` | Listener notification on event processed; watermark draining order under concurrent keys | | `ActionTaskContextManager` | Full memory-context lifecycle (create → transfer → complete → cleanup) | ## Notes - The contract tests added in PR #546 (`e2e4e03`) cover the core promise of each manager but use mocks and simple stubs. - Flink-harness tests require `AbstractStreamOperatorTestHarness` and real Flink state backends — heavier setup, better suited to a focused follow-up. - These tests were deferred by explicit agreement with reviewers @xintongsong and @wenjin272 to keep PR #546 reviewable. ### Are you willing to submit a PR? - [x] I'm willing to submit a PR! -- 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]
