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(-)
