Skip to content

test(amber): add unit test coverage for ExecutionUtils #4569

@aglinxinyuan

Description

@aglinxinyuan

Task Summary

ExecutionUtils (amber/src/main/scala/org/apache/texera/amber/engine/architecture/controller/execution/ExecutionUtils.scala) provides three pure aggregator functions used to roll up runtime statistics across regions/operators/ports, but currently has no unit tests. Add ExecutionUtilsSpec covering:

  • aggregateStates — empty, all-completed, all-terminated, has-running, all-uninitialized, all-paused, all-ready (maps to RUNNING), mixed (UNKNOWN)
  • aggregatePortMetrics — empty, single mapping, sum-on-same-port, group-by-port-id
  • aggregateMetrics — empty defaults, scalar sum + per-port merge across operators, internal-port filtering

Priority

P3 – Low

Task Type

  • Testing / QA

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    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