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/12/28 20:31:34 UTC

[beam] 01/01: Merge pull request #7360 [BEAM-6294] Use Flink rebalance for shuffle.

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 9f2eb341b2c2ba19da192b091e545436315c1120
Merge: d1384b9 4e8a07b
Author: Robert Bradshaw <ro...@gmail.com>
AuthorDate: Fri Dec 28 21:31:26 2018 +0100

    Merge pull request #7360 [BEAM-6294] Use Flink rebalance for shuffle.

 .../FlinkBatchPortablePipelineTranslator.java      | 34 ++++++++-
 .../beam/runners/flink/FlinkJobInvocation.java     | 82 ++++++++++++++++------
 .../flink/FlinkPortablePipelineTranslator.java     | 19 ++++-
 .../FlinkStreamingPortablePipelineTranslator.java  | 23 +++++-
 sdks/python/apache_beam/transforms/util.py         |  8 +++
 5 files changed, 137 insertions(+), 29 deletions(-)