This is an automated email from the ASF dual-hosted git repository.
tgroh pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from feb1027 Merge pull request #5202: [BEAM-4066] Fix Nexmark fails when
running with PubSub
add 6686b91 [BEAM-4149] Set worker id to "" if it is not set in the
request header
add 0aaf8ec [BEAM-3327] Refactor ControlClientPool to allow client
multiplexing
add ff81f7a [BEAM-3327] Basic Docker environment factory
add 756812f Merge pull request #5189: Basic Docker environment factory
No new revisions were added by this update.
Summary of changes:
runners/java-fn-execution/build.gradle | 15 ++
runners/java-fn-execution/pom.xml | 47 +++++++
.../GrpcContextHeaderAccessorProvider.java | 9 +-
.../fnexecution/control/ControlClientPool.java | 62 ++++++++-
.../control/FnApiControlClientPoolService.java | 60 +++++---
.../control/InstructionRequestHandler.java | 3 +-
.../fnexecution/control/MapControlClientPool.java | 78 +++++++++++
.../control/QueueControlClientPool.java | 62 ---------
.../fnexecution/environment/DockerCommand.java | 142 +++++++++++++++++++
.../environment/DockerContainerEnvironment.java | 86 ++++++++++++
.../environment/DockerEnvironmentFactory.java | 154 +++++++++++++++++++++
.../environment/EnvironmentFactory.java | 14 +-
.../environment/testing/NeedsDocker.java | 9 +-
.../environment/testing}/package-info.java | 6 +-
.../runners/fnexecution/InProcessSdkHarness.java | 27 +++-
.../control/FnApiControlClientPoolServiceTest.java | 12 +-
.../fnexecution/control/RemoteExecutionTest.java | 7 +-
.../fnexecution/control/SdkHarnessClientTest.java | 5 +-
.../fnexecution/environment/DockerCommandTest.java | 84 +++++++++++
.../environment/DockerEnvironmentFactoryTest.java | 122 ++++++++++++++++
20 files changed, 873 insertions(+), 131 deletions(-)
create mode 100644
runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/MapControlClientPool.java
delete mode 100644
runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/QueueControlClientPool.java
create mode 100644
runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/environment/DockerCommand.java
create mode 100644
runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/environment/DockerContainerEnvironment.java
create mode 100644
runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/environment/DockerEnvironmentFactory.java
copy
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/UsesParDoLifecycle.java
=>
runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/environment/testing/NeedsDocker.java
(83%)
copy
runners/{apex/src/main/java/org/apache/beam/runners/apex/translation/operators
=>
java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/environment/testing}/package-info.java
(86%)
create mode 100644
runners/java-fn-execution/src/test/java/org/apache/beam/runners/fnexecution/environment/DockerCommandTest.java
create mode 100644
runners/java-fn-execution/src/test/java/org/apache/beam/runners/fnexecution/environment/DockerEnvironmentFactoryTest.java
--
To stop receiving notification emails like this one, please contact
[email protected].
