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 2018/10/23 12:49:30 UTC

[beam] 01/01: Merge pull request #6752 [BEAM-5791] Dataflow harness data plane pushback.

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 72e0e6d710b5e08208f1063965a922cd7b86cb61
Merge: f5ba855 50bd6b8
Author: Robert Bradshaw <ro...@gmail.com>
AuthorDate: Tue Oct 23 14:49:22 2018 +0200

    Merge pull request #6752 [BEAM-5791] Dataflow harness data plane pushback.
    
    [BEAM-5791] Implement time-based pushback in the dataflow harness data plane.

 .../worker/fn/control/BeamFnMapTaskExecutor.java   |  43 +++++---
 .../fn/data/RemoteGrpcPortWriteOperation.java      | 111 ++++++++++++++++++++-
 .../dataflow/worker/FnApiWindowMappingFnTest.java  |   3 +
 .../fn/control/BeamFnMapTaskExecutorTest.java      |   2 +
 .../SingularProcessBundleProgressTrackerTest.java  |   2 +
 .../fn/data/RemoteGrpcPortWriteOperationTest.java  |  83 ++++++++++++++-
 .../data/BeamFnDataBufferingOutboundObserver.java  |   9 +-
 .../beam/sdk/fn/data/CloseableFnDataReceiver.java  |  11 ++
 8 files changed, 247 insertions(+), 17 deletions(-)