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

Posted to commits@beam.apache.org by ke...@apache.org on 2018/10/27 01:59:10 UTC

[beam] branch master updated (52721a1 -> a7c3078)

This is an automated email from the ASF dual-hosted git repository.

kenn pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.


    from 52721a1  Merge pull request #6801 from charlesccychen/multi-snappy
     add 8632186  Revert "Merge pull request #6837 [BEAM-5853] Fix in RemoteGrpcPortWriteOperation"
     add e17731e  Revert "Merge pull request #6807: [BEAM-5833] Fix java-harness build by adding flush() to BeamFnDataWriteRunnerTest"
     add a96f111  Revert "Merge pull request #6798: [BEAM-5833] Fix checkstyle breakage"
     add ddd775d  Revert "Merge pull request #6752 [BEAM-5791] Dataflow harness data plane pushback."
     add a7c3078  Merge pull request #6855: Revert #6752 #6798 #6807 #6837 to fix Dataflow test breakage

No new revisions were added by this update.

Summary of changes:
 .../worker/fn/control/BeamFnMapTaskExecutor.java   |  43 +++-----
 .../fn/data/RemoteGrpcPortWriteOperation.java      | 110 +--------------------
 .../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 ---
 .../beam/fn/harness/BeamFnDataWriteRunnerTest.java |  10 --
 9 files changed, 17 insertions(+), 256 deletions(-)