You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ro...@apache.org on 2020/05/12 17:36:21 UTC
[beam] branch master updated (d8e8616 -> 3584015)

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

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


    from d8e8616  [BEAM-9945] Report data channel progress via a designated counter. (#11652)
     add 3584015  [BEAM-9577] Update Java Runners to handle dependency-based artifact staging. (#11521)

No new revisions were added by this update.

Summary of changes:
 .../runners/flink/FlinkJobServerDriverTest.java    |  2 +-
 .../beam/runners/fnexecution/GrpcFnServer.java     | 56 +++++++++++++++++
 .../artifact/ArtifactStagingService.java           | 51 ++++++++++++++--
 .../control/DefaultJobBundleFactory.java           | 42 ++++++++++---
 .../SingleEnvironmentInstanceJobBundleFactory.java |  2 +-
 .../environment/DockerEnvironmentFactory.java      |  8 +--
 .../environment/EmbeddedEnvironmentFactory.java    |  9 +--
 .../environment/EnvironmentFactory.java            |  7 ++-
 .../environment/ExternalEnvironmentFactory.java    | 14 ++---
 .../environment/ProcessEnvironmentFactory.java     |  8 +--
 .../StaticRemoteEnvironmentFactory.java            |  6 +-
 .../provisioning/StaticGrpcProvisionService.java   | 36 +++++++++--
 .../runners/fnexecution/EmbeddedSdkHarness.java    |  2 +-
 .../control/DefaultJobBundleFactoryTest.java       | 71 ++++++++++++----------
 ...gleEnvironmentInstanceJobBundleFactoryTest.java | 14 +++--
 .../environment/DockerEnvironmentFactoryTest.java  | 12 ++--
 .../environment/ProcessEnvironmentFactoryTest.java | 13 ++--
 .../StaticGrpcProvisionServiceTest.java            |  5 +-
 .../runners/jobsubmission/InMemoryJobService.java  | 65 ++++++++++++++++----
 .../runners/jobsubmission/JobServerDriver.java     | 43 ++++++++-----
 .../jobsubmission/InMemoryJobServiceTest.java      | 18 ++++--
 .../beam/runners/portability/PortableRunner.java   |  1 +
 .../beam/runners/samza/SamzaExecutionContext.java  |  3 +-
 23 files changed, 356 insertions(+), 132 deletions(-)