[ https://issues.apache.org/jira/browse/BEAM-89 ]
Danny McCormick deleted comment on BEAM-89:
-------------------------------------
was (Author: JIRAUSER282469):
This isn't actually real, but this issue has been migrated to
https://github.com/apache/beam/issues/17846
> DataflowPipelineJob should have an API that prints messages but doesn't wait
> for completion
> -------------------------------------------------------------------------------------------
>
> Key: BEAM-89
> URL: https://issues.apache.org/jira/browse/BEAM-89
> Project: Beam
> Issue Type: Improvement
> Components: sdk-java-core
> Reporter: Eugene Kirpichov
> Priority: P3
> Labels: Clarified
>
> DataflowPipelineJob has a method waitToFinish() that takes a handler for
> printing the job's output messages, AND waits for the job to finish, printing
> messages along the way using that handler.
> However, there are cases when a caller would like to poll for the job's
> messages and print them, but would like to keep the job under the caller's
> control, rather than having to wait for it to complete.
> E.g., one can imagine wanting to do the following "wait until a certain
> Aggregator in the job reaches a certain value, and then cancel the job,
> printing messages along the way". This is not possible with the current API,
> without copying code of waitToFinish().
--
This message was sent by Atlassian Jira
(v8.20.7#820007)
