Closes #1160
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/48fdd067 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/48fdd067 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/48fdd067 Branch: refs/heads/apex-runner Commit: 48fdd06760ded8bb2010b12fad430068a06bdec6 Parents: 09a80ec 1559a7f Author: Dan Halperin <dhalp...@google.com> Authored: Wed Oct 26 14:47:10 2016 -0700 Committer: Dan Halperin <dhalp...@google.com> Committed: Wed Oct 26 14:47:10 2016 -0700 ---------------------------------------------------------------------- .../apache/beam/runners/direct/DirectRunner.java | 2 +- .../runners/dataflow/BlockingDataflowRunner.java | 13 +------------ .../beam/runners/dataflow/DataflowPipelineJob.java | 17 +++++++++++++---- .../spark/translation/EvaluationContext.java | 6 ++---- .../streaming/StreamingEvaluationContext.java | 6 ++---- .../java/org/apache/beam/sdk/PipelineResult.java | 10 ++-------- 6 files changed, 21 insertions(+), 33 deletions(-) ----------------------------------------------------------------------
