This is an automated email from the ASF dual-hosted git repository. robertwb pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git
commit 0389f54ccd5c018f75c883bafa6be959503a9b58 Merge: 2f25e62 c15a7e2 Author: Robert Bradshaw <rober...@google.com> AuthorDate: Fri Mar 20 16:23:37 2020 -0700 Merge pull request #11173 [BEAM-9558] Add explicit end bit for data channel. .../fn-execution/src/main/proto/beam_fn_api.proto | 13 +- .../worker/fn/data/BeamFnDataGrpcServiceTest.java | 5 +- .../fnexecution/data/GrpcDataServiceTest.java | 5 +- sdks/go/pkg/beam/core/runtime/harness/datamgr.go | 4 +- .../beam/model/fnexecution_v1/beam_fn_api.pb.go | 454 ++++++++++----------- .../sdk/fn/data/BeamFnDataInboundObserver.java | 3 +- ...amFnDataSizeBasedBufferingOutboundObserver.java | 3 +- ...DataSizeBasedBufferingOutboundObserverTest.java | 21 +- .../fn/harness/data/BeamFnDataGrpcClientTest.java | 6 +- .../apache_beam/runners/worker/data_plane.py | 14 +- 10 files changed, 276 insertions(+), 252 deletions(-)