Skip to content

[Tech Debt] [runtime] Add comprehensive tests for ActionExecutionOperator manager classes #646

@weiqingy

Description

@weiqingy

Search before asking

  • I searched in the 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

Are you willing to submit a PR?

  • I'm willing to submit a PR!

Metadata

Metadata

Assignees

No one assigned

    Labels

    priority/majorDefault priority of the PR or issue.tech debt[Issue Type] User-unaware issues, such as code refactor and infrastructure maintenance.

    Type

    No type
    No fields configured for issues without a type.

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions