Details
-
Improvement
-
Status: Open
-
P3
-
Resolution: Unresolved
-
None
-
None
Description
Current state:
Jira https://issues.apache.org/jira/browse/BEAM-443 addresses waitUntilFinish() and cancel().
However, there are additional work around PipelineResult:
need clearly defined contract and verification across all runners
need to revisit how to handle metrics/aggregators
need to be able to get logs