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

Posted to commits@beam.apache.org by th...@apache.org on 2019/11/16 00:51:13 UTC

[beam] branch master updated (7beb9ee -> 1386b94)

This is an automated email from the ASF dual-hosted git repository.

thw pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.


    from 7beb9ee  Merge pull request #10117 [BEAM-8335] Add service and tagged output capabilities to TestStream
     add 45dc280  [BEAM-8670] Manage environment parallelism in DefaultJobBundleFactory
     add 1386b94  Merge pull request #10124: [BEAM-8670] Manage environment parallelism in DefaultJobBundleFactory

No new revisions were added by this update.

Summary of changes:
 .../FlinkExecutableStageContextFactory.java        |  21 ++--
 .../control/DefaultExecutableStageContext.java     |  56 +----------
 .../control/DefaultJobBundleFactory.java           | 107 ++++++++++++++-------
 .../control/DefaultExecutableStageContextTest.java |  72 --------------
 .../control/DefaultJobBundleFactoryTest.java       |  72 ++++++++++++++
 .../SparkExecutableStageContextFactory.java        |  24 ++---
 6 files changed, 158 insertions(+), 194 deletions(-)
 delete mode 100644 runners/java-fn-execution/src/test/java/org/apache/beam/runners/fnexecution/control/DefaultExecutableStageContextTest.java