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 ba9a7ff Merge pull request #9648 from angoenka/flink_options add 17805bc [BEAM-8313] Rename certain proto fields to be consistent across fn/runner APIs No new revisions were added by this update. Summary of changes: .../fn-execution/src/main/proto/beam_fn_api.proto | 40 +- .../streaming/ExecutableStageDoFnOperatorTest.java | 2 +- .../dataflow/worker/FnApiWindowMappingFn.java | 2 +- .../control/RegisterAndProcessBundleOperation.java | 26 +- .../logging/DataflowWorkerLoggingHandler.java | 6 +- .../dataflow/worker/FnApiWindowMappingFnTest.java | 3 +- .../RegisterAndProcessBundleOperationTest.java | 13 +- .../worker/fn/data/BeamFnDataGrpcServiceTest.java | 12 +- .../fn/logging/BeamFnLoggingServiceTest.java | 18 +- .../logging/DataflowWorkerLoggingHandlerTest.java | 2 +- .../fnexecution/control/SdkHarnessClient.java | 2 +- .../fnexecution/state/GrpcStateService.java | 5 +- .../fnexecution/state/StateRequestHandlers.java | 6 +- .../runners/fnexecution/ServerFactoryTest.java | 4 +- .../fnexecution/data/GrpcDataServiceTest.java | 12 +- .../logging/GrpcLoggingServiceTest.java | 18 +- .../fnexecution/state/GrpcStateServiceTest.java | 4 +- sdks/go/pkg/beam/core/runtime/exec/translate.go | 2 +- sdks/go/pkg/beam/core/runtime/harness/datamgr.go | 12 +- .../pkg/beam/core/runtime/harness/datamgr_test.go | 6 +- sdks/go/pkg/beam/core/runtime/harness/harness.go | 6 +- sdks/go/pkg/beam/core/runtime/harness/logging.go | 4 +- sdks/go/pkg/beam/core/runtime/harness/statemgr.go | 12 +- sdks/go/pkg/beam/doc_test.go | 4 +- .../beam/model/fnexecution_v1/beam_fn_api.pb.go | 599 +++++---- .../model/jobmanagement_v1/beam_artifact_api.pb.go | 125 +- .../beam/model/pipeline_v1/beam_runner_api.pb.go | 1364 ++++++-------------- .../data/BeamFnDataBufferingOutboundObserver.java | 8 +- .../sdk/fn/data/BeamFnDataGrpcMultiplexer.java | 11 +- .../sdk/fn/data/BeamFnDataInboundObserver.java | 4 +- .../BeamFnDataBufferingOutboundObserverTest.java | 8 +- .../sdk/fn/data/BeamFnDataGrpcMultiplexerTest.java | 8 +- .../harness/SplittableProcessElementsRunner.java | 4 +- .../fn/harness/control/ProcessBundleHandler.java | 6 +- .../apache/beam/fn/harness/state/BagUserState.java | 4 +- .../beam/fn/harness/state/FnApiStateAccessor.java | 4 +- .../beam/fn/harness/state/MultimapSideInput.java | 4 +- .../beam/fn/harness/FnApiDoFnRunnerTest.java | 4 +- .../harness/control/ProcessBundleHandlerTest.java | 28 +- .../fn/harness/data/BeamFnDataGrpcClientTest.java | 20 +- .../data/BeamFnDataInboundObserverTest.java | 4 +- .../harness/data/QueueingBeamFnDataClientTest.java | 20 +- .../beam/fn/harness/state/BagUserStateTest.java | 2 +- .../state/BeamFnStateGrpcClientCacheTest.java | 14 +- .../fn/harness/state/MultimapSideInputTest.java | 2 +- .../runners/portability/fn_api_runner.py | 40 +- .../apache_beam/runners/worker/bundle_processor.py | 14 +- .../apache_beam/runners/worker/data_plane.py | 22 +- .../apache_beam/runners/worker/data_plane_test.py | 16 +- .../apache_beam/runners/worker/sdk_worker.py | 36 +- 50 files changed, 1001 insertions(+), 1591 deletions(-)