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 tg...@apache.org.