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%)