You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by lc...@apache.org on 2021/10/26 22:23:06 UTC

[beam] branch master updated (62b33a5 -> 95d1f9a)

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

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


    from 62b33a5  Change sql.Options to an interface under sqlx. (#15790)
     add 95d1f9a  [BEAM-4149] Ensure that we always provide and require the worker id.

No new revisions were added by this update.

Summary of changes:
 .../worker/fn/BeamFnControlServiceTest.java        | 25 +++++--
 .../worker/fn/data/BeamFnDataGrpcServiceTest.java  | 87 ++++++++--------------
 .../fn/logging/BeamFnLoggingServiceTest.java       | 48 +++++++-----
 .../control/FnApiControlClientPoolService.java     |  6 --
 .../environment/EmbeddedEnvironmentFactory.java    |  3 +-
 .../provisioning/StaticGrpcProvisionService.java   |  3 +-
 .../runners/fnexecution/EmbeddedSdkHarness.java    |  4 +-
 .../control/FnApiControlClientPoolServiceTest.java | 54 +++++++++-----
 .../fnexecution/control/RemoteExecutionTest.java   |  7 +-
 .../StaticGrpcProvisionServiceTest.java            |  5 +-
 .../status/BeamWorkerStatusGrpcServiceTest.java    |  2 +-
 .../sdk/fn/channel}/AddHarnessIdInterceptor.java   |  2 +-
 .../server/GrpcContextHeaderAccessorProvider.java  | 11 +--
 .../beam/fn/harness/ProcessBundleBenchmark.java    |  7 +-
 .../java/org/apache/beam/fn/harness/FnHarness.java |  7 +-
 15 files changed, 135 insertions(+), 136 deletions(-)
 rename sdks/java/{harness/src/main/java/org/apache/beam/fn/harness/control => fn-execution/src/main/java/org/apache/beam/sdk/fn/channel}/AddHarnessIdInterceptor.java (97%)