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:29 UTC
[beam] branch master updated (f5ba855 -> 72e0e6d)
This is an automated email from the ASF dual-hosted git repository.
robertwb pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from f5ba855 Merge pull request #6792 [BEAM-5793] Disable pylint 'self-argument' check
add 50bd6b8 [BEAM-5791] Implement time-based pushback in the dataflow harness data plane.
new 72e0e6d Merge pull request #6752 [BEAM-5791] Dataflow harness data plane pushback.
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../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(-)
[beam] 01/01: Merge pull request #6752 [BEAM-5791] Dataflow harness
data plane pushback.
Posted by ro...@apache.org.
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(-)