[ https://issues.apache.org/jira/browse/BEAM-89?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Davor Bonaci updated BEAM-89: ----------------------------- Assignee: (was: Davor Bonaci) > 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: Minor > > 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 (v6.3.4#6332)