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 e33da0d Merge pull request #5530: [SQL] BeamSqlEnv refactor
add 6b4eed8 Use the Current Users Container as the Environment
add 4949cc9 Enable Docker in the PortableDirectRunner
add 76fb544 Move DirectJobBundleFactory to fn-execution
add d0a02f0 Cleanups to the PortableDirectRunner
add f7476a8 Cleanups and Wiring for the ReferenceRunnerJobService
add d6fc2f2 Use an UnsupportedArtifactRetrievalService
new 4511734 Merge pull request #5535: Use Docker in the ReferenceRunner
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../runners/core/construction/Environments.java | 5 +-
.../runners/direct/portable/QuiescenceDriver.java | 1 +
.../runners/direct/portable/ReferenceRunner.java | 100 ++++++++++++--
.../portable/RemoteStageEvaluatorFactory.java | 2 +-
.../portable/TransformEvaluatorRegistry.java | 1 -
...va => UnsupportedArtifactRetrievalService.java} | 25 +++-
.../portable/job/ReferenceRunnerJobService.java | 48 +++++--
.../direct/portable/ReferenceRunnerTest.java | 12 +-
.../portable/RemoteStageEvaluatorFactoryTest.java | 4 +-
.../UnsupportedArtifactRetrievalServiceTest.java | 153 +++++++++++++++++++++
...SingleEnvironmentInstanceJobBundleFactory.java} | 31 +++--
.../fnexecution/control/RemoteExecutionTest.java | 111 ++++++++-------
...leEnvironmentInstanceJobBundleFactoryTest.java} | 12 +-
.../src/main/resources/beam/findbugs-filter.xml | 7 +
14 files changed, 407 insertions(+), 105 deletions(-)
copy
runners/direct-java/src/main/java/org/apache/beam/runners/direct/portable/artifact/{package-info.java
=> UnsupportedArtifactRetrievalService.java} (56%)
create mode 100644
runners/direct-java/src/test/java/org/apache/beam/runners/direct/portable/artifact/UnsupportedArtifactRetrievalServiceTest.java
rename
runners/{direct-java/src/main/java/org/apache/beam/runners/direct/portable/DirectJobBundleFactory.java
=>
java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/SingleEnvironmentInstanceJobBundleFactory.java}
(86%)
rename
runners/{direct-java/src/test/java/org/apache/beam/runners/direct/portable/DirectJobBundleFactoryTest.java
=>
java-fn-execution/src/test/java/org/apache/beam/runners/fnexecution/control/SingleEnvironmentInstanceJobBundleFactoryTest.java}
(95%)
--
To stop receiving notification emails like this one, please contact
[email protected].
