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

Posted to commits@beam.apache.org by xi...@apache.org on 2021/09/29 19:03:34 UTC

[beam] branch master updated (b7603eb -> 2617ef6)

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

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


    from b7603eb  Merge pull request #15561: [BEAM-12942] Validate pubsub messages before they are published in PubsubIO
     add 2617ef6  [BEAM-12977] Translates Reshuffle in Portable Mode with Samza native repartition operator (#15601)

No new revisions were added by this update.

Summary of changes:
 .../samza/translation/ReshuffleTranslator.java     | 40 ++++++++++++++++++++++
 .../SamzaPortablePipelineTranslator.java           |  1 +
 2 files changed, 41 insertions(+)