This closes #2074
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/17ab371f Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/17ab371f Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/17ab371f Branch: refs/heads/master Commit: 17ab371f13a151d03315889e79e69c06ac77ac1d Parents: 0f9fefe 26c42b9 Author: Dan Halperin <dhalp...@google.com> Authored: Wed Feb 22 14:47:52 2017 -0800 Committer: Dan Halperin <dhalp...@google.com> Committed: Wed Feb 22 14:47:52 2017 -0800 ---------------------------------------------------------------------- .../beam/runners/dataflow/DataflowClient.java | 44 +++--- .../runners/dataflow/DataflowPipelineJob.java | 2 +- .../options/DataflowPipelineOptions.java | 17 +++ .../dataflow/DataflowPipelineJobTest.java | 153 +++++++++++-------- .../runners/dataflow/DataflowRunnerTest.java | 64 ++++---- 5 files changed, 168 insertions(+), 112 deletions(-) ----------------------------------------------------------------------
