This is an automated email from the ASF dual-hosted git repository.
jkff pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 809fcf9 Merge pull request #5702 from [BEAM-4605] Remove subtransform
of GBK.
add f0da541 Add an AddHarnessIdInterceptor
add c097034 Remove the runners/reference InProcessManagedChannelFactory
add 33616cc Allow ManagedChannelFactories to attach Interceptors
add 04e77aa Populate and Use Harness IDs in the Java Harness
add 56f1ecc Fixes checkstyle
new 77e93d9 Merge pull request #5680: [BEAM-4145] Populate the worker_id
metadata in the Java SDK Harness
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:
.../environment/InProcessEnvironmentFactory.java | 1 +
.../fnexecution/control/RemoteExecutionTest.java | 1 +
.../testing/InProcessManagedChannelFactory.java | 36 -----------
sdks/go/pkg/beam/util/grpcx/metadata.go | 2 +-
sdks/java/container/boot.go | 1 +
.../beam/sdk/fn/channel/ManagedChannelFactory.java | 63 ++++++++++++++----
.../fn/test/InProcessManagedChannelFactory.java | 6 +-
.../java/org/apache/beam/fn/harness/FnHarness.java | 75 ++++++++++++----------
.../harness/control/AddHarnessIdInterceptor.java} | 33 +++++-----
.../fn/harness/control/BeamFnControlClient.java | 17 +++--
.../org/apache/beam/fn/harness/FnHarnessTest.java | 2 +-
.../harness/control/BeamFnControlClientTest.java | 15 ++---
12 files changed, 134 insertions(+), 118 deletions(-)
delete mode 100644
runners/reference/java/src/main/java/org/apache/beam/runners/reference/testing/InProcessManagedChannelFactory.java
copy
sdks/java/{extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/interpreter/operator/BeamSqlBinaryOperator.java
=>
harness/src/main/java/org/apache/beam/fn/harness/control/AddHarnessIdInterceptor.java}
(52%)
