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
