You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by ro...@apache.org on 2020/03/20 23:23:55 UTC

[beam] 01/01: Merge pull request #11173 [BEAM-9558] Add explicit end bit for data channel.

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 <ro...@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(-)