[jira] [Commented] (BEAM-443) PipelineResult needs waitToFinish() and cancel()
[ https://issues.apache.org/jira/browse/BEAM-443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15573284#comment-15573284 ] ASF GitHub Bot commented on BEAM-443: - GitHub user peihe opened a pull request: https://github.com/apache/incubator-beam/pull/1097 [BEAM-443] Update Beam batch examples to call waitUntilFinish() You can merge this pull request into a Git repository by running: $ git pull https://github.com/peihe/incubator-beam waitInExample Alternatively you can review and apply these changes as the patch at: https://github.com/apache/incubator-beam/pull/1097.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #1097 commit 6ac9e9930208dfdf0789a066243048e5a01c9f5e Author: Pei He Date: 2016-10-13T21:44:13Z [BEAM-443] Update Beam batch examples to call waitUntilFinish() > PipelineResult needs waitToFinish() and cancel() > > > Key: BEAM-443 > URL: https://issues.apache.org/jira/browse/BEAM-443 > Project: Beam > Issue Type: New Feature >Reporter: Pei He >Assignee: Pei He > Fix For: 0.2.0-incubating > > > waitToFinish() and cancel() are two most common operations for users to > interact with a started pipeline. > Right now, they are only available in DataflowPipelineJob. But, it is better > to move them to the common interface, so people can start implement them in > other runners, and runner agnostic code can interact with PipelineResult > better. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (BEAM-443) PipelineResult needs waitToFinish() and cancel()
[ https://issues.apache.org/jira/browse/BEAM-443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15400156#comment-15400156 ] ASF GitHub Bot commented on BEAM-443: - GitHub user peihe opened a pull request: https://github.com/apache/incubator-beam/pull/762 [BEAM-443] Remove BlockingDataflowRunner You can merge this pull request into a Git repository by running: $ git pull https://github.com/peihe/incubator-beam rm-blocking-runner Alternatively you can review and apply these changes as the patch at: https://github.com/apache/incubator-beam/pull/762.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #762 commit c5850d0593f0c0fd6c64f9992f335b8eb42e7a66 Author: Pei He Date: 2016-07-29T22:40:07Z Remove BlockingDataflowRunner > PipelineResult needs waitToFinish() and cancel() > > > Key: BEAM-443 > URL: https://issues.apache.org/jira/browse/BEAM-443 > Project: Beam > Issue Type: New Feature >Reporter: Pei He >Assignee: Pei He > > waitToFinish() and cancel() are two most common operations for users to > interact with a started pipeline. > Right now, they are only available in DataflowPipelineJob. But, it is better > to move them to the common interface, so people can start implement them in > other runners, and runner agnostic code can interact with PipelineResult > better. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (BEAM-443) PipelineResult needs waitToFinish() and cancel()
[ https://issues.apache.org/jira/browse/BEAM-443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15398635#comment-15398635 ] ASF GitHub Bot commented on BEAM-443: - Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/642 > PipelineResult needs waitToFinish() and cancel() > > > Key: BEAM-443 > URL: https://issues.apache.org/jira/browse/BEAM-443 > Project: Beam > Issue Type: New Feature >Reporter: Pei He >Assignee: Pei He > > waitToFinish() and cancel() are two most common operations for users to > interact with a started pipeline. > Right now, they are only available in DataflowPipelineJob. But, it is better > to move them to the common interface, so people can start implement them in > other runners, and runner agnostic code can interact with PipelineResult > better. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (BEAM-443) PipelineResult needs waitToFinish() and cancel()
[ https://issues.apache.org/jira/browse/BEAM-443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15373727#comment-15373727 ] ASF GitHub Bot commented on BEAM-443: - GitHub user peihe opened a pull request: https://github.com/apache/incubator-beam/pull/642 [BEAM-443] Add waitToFinish() and cancel() in PipelineResult. You can merge this pull request into a Git repository by running: $ git pull https://github.com/peihe/incubator-beam cancel-job Alternatively you can review and apply these changes as the patch at: https://github.com/apache/incubator-beam/pull/642.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #642 commit a42899098bd889e4649fe4a67a0c017733148b41 Author: Pei He Date: 2016-07-12T02:42:02Z [BEAM-443] Add waitToFinish() and cancel() in PipelineResult. > PipelineResult needs waitToFinish() and cancel() > > > Key: BEAM-443 > URL: https://issues.apache.org/jira/browse/BEAM-443 > Project: Beam > Issue Type: New Feature >Reporter: Pei He >Assignee: Pei He > > waitToFinish() and cancel() are two most common operations for users to > interact with a started pipeline. > Right now, they are only available in DataflowPipelineJob. But, it is better > to move them to the common interface, so people can start implement them in > other runners, and runner agnostic code can interact with PipelineResult > better. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
