[beam] branch master updated (f80aeb1 -> cac06ce)

[ti...@apache.org]

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

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


    from f80aeb1  Merge pull request #6877: Add CountDownLatch to racy Dataflow Worker test
     add a1a798a  [BEAM-4783] Fix invalid parameter to set the partitioner in Spark GbK
     new cac06ce  Merge pull request #6884: [BEAM-4783] Fix invalid parameter to set the partitioner in Spark GbK

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:
 .../apache/beam/runners/spark/io/SourceRDD.java    | 11 ++++----
 .../spark/translation/GroupCombineFunctions.java   | 32 ++++++++++------------
 .../spark/translation/TransformTranslator.java     | 21 +++++++-------
 .../streaming/StreamingTransformTranslator.java    |  2 +-
 4 files changed, 31 insertions(+), 35 deletions(-)

[beam] 01/01: Merge pull request #6884: [BEAM-4783] Fix invalid parameter to set the partitioner in Spark GbK

[ti...@apache.org]

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

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

commit cac06ce4bd2a8e233010f47f5ceb988ea0f28e35
Merge: f80aeb1 a1a798a
Author: Tim Robertson <ti...@gmail.com>
AuthorDate: Tue Oct 30 15:34:21 2018 +0100

    Merge pull request #6884: [BEAM-4783] Fix invalid parameter to set the partitioner in Spark GbK

 .../apache/beam/runners/spark/io/SourceRDD.java    | 11 ++++----
 .../spark/translation/GroupCombineFunctions.java   | 32 ++++++++++------------
 .../spark/translation/TransformTranslator.java     | 21 +++++++-------
 .../streaming/StreamingTransformTranslator.java    |  2 +-
 4 files changed, 31 insertions(+), 35 deletions(-)