Search before asking
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
Are you willing to submit a PR?
Search before asking
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
OperatorStateManagerStateInitializationContext, keyed state, operator state backend)DurableExecutionManagernotifyCheckpointCompletepruning behaviourEventRouterActionTaskContextManagerNotes
e2e4e03) cover the core promise of each manager but use mocks and simple stubs.AbstractStreamOperatorTestHarnessand real Flink state backends — heavier setup, better suited to a focused follow-up (keep PR [runtime] Refactor ActionExecutionOperator into focused manager classes #546 reviewable).Are you willing to submit a PR?