Check Dataflow Job Status Before Terminate

This closes #951


Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/9e7ed292
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/9e7ed292
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/9e7ed292

Branch: refs/heads/master
Commit: 9e7ed29290911bb341261240d8d799bd7f0a4e9b
Parents: 9c8e19c e776ae7
Author: Luke Cwik <lc...@google.com>
Authored: Mon Sep 19 21:30:04 2016 -0700
Committer: Luke Cwik <lc...@google.com>
Committed: Mon Sep 19 21:30:04 2016 -0700

----------------------------------------------------------------------
 .../runners/dataflow/DataflowPipelineJob.java   | 19 +++--
 .../dataflow/DataflowPipelineJobTest.java       | 74 ++++++++++++++++++++
 2 files changed, 87 insertions(+), 6 deletions(-)
----------------------------------------------------------------------


Reply via email to