[beam] branch master updated (ba9a7ff -> 17805bc)

[lc...@apache.org]

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