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 36bdff42e8e Support key iteration in Python ULR. (#29839)
add 7827d1d1809 Fix Reshuffle implementation in Java SDK
add 8bb66105689 Merge pull request #28853: Fix Reshuffle implementation in
Java SDK
No new revisions were added by this update.
Summary of changes:
runners/flink/flink_runner.gradle | 2 +
runners/flink/job-server/flink_job_server.gradle | 2 +
runners/samza/src/test/resources/ExpectedDag.json | 68 ++++------
.../org/apache/beam/sdk/transforms/Reshuffle.java | 89 +++++++++++++
.../apache/beam/sdk/transforms/ReshuffleTest.java | 139 +++++++++++++++++++++
5 files changed, 253 insertions(+), 47 deletions(-)
