You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by jb...@apache.org on 2017/07/20 19:53:24 UTC

[28/50] [abbrv] beam git commit: This closes #3455

This closes #3455


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

Branch: refs/heads/DSL_SQL
Commit: dd9e866e087351e395e464e07d512b2e8db107c4
Parents: 2d5b6d7 111603a
Author: Thomas Groh <tg...@google.com>
Authored: Tue Jul 18 14:49:56 2017 -0700
Committer: Thomas Groh <tg...@google.com>
Committed: Tue Jul 18 14:49:56 2017 -0700

----------------------------------------------------------------------
 .../beam/runners/dataflow/DataflowPipelineJob.java  | 14 ++++++++++++--
 .../beam/runners/dataflow/DataflowRunner.java       |  3 ++-
 .../beam/runners/dataflow/util/MonitoringUtil.java  | 16 +++++++++++++---
 .../dataflow/BatchStatefulParDoOverridesTest.java   |  1 +
 .../dataflow/DataflowPipelineTranslatorTest.java    |  1 +
 .../runners/dataflow/internal/apiclient.py          |  7 +++++--
 .../runners/dataflow/test_dataflow_runner.py        |  5 +++--
 7 files changed, 37 insertions(+), 10 deletions(-)
----------------------------------------------------------------------