This closes #2407
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/844e53e3 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/844e53e3 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/844e53e3 Branch: refs/heads/master Commit: 844e53e341bf6d465e4185903a3a5047a3e68282 Parents: 3711c0c 6b7593b Author: Dan Halperin <[email protected]> Authored: Mon Apr 3 15:58:11 2017 -0700 Committer: Dan Halperin <[email protected]> Committed: Mon Apr 3 15:58:11 2017 -0700 ---------------------------------------------------------------------- .../beam/runners/dataflow/DataflowRunner.java | 18 ++++++++++---- .../options/DataflowPipelineDebugOptions.java | 2 +- .../DataflowPipelineWorkerPoolOptions.java | 10 +------- .../runners/dataflow/DataflowRunnerTest.java | 25 ++++++++++++++++++++ 4 files changed, 41 insertions(+), 14 deletions(-) ----------------------------------------------------------------------
