This is an automated email from the ASF dual-hosted git repository.
dmvk pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from ded0325 [BEAM-11075] Go SDK SideInput load tests (#13436)
add f1c1514 [BEAM-11267] Remove unecessary reshuffle for stateful ParDo
after keyed operation.
add 76c6129 Merge pull request #13353: [BEAM-11267] Remove unnecessary
reshuffle for stateful ParDo after key…
No new revisions were added by this update.
Summary of changes:
.../FlinkStreamingPortablePipelineTranslator.java | 4 +-
.../flink/FlinkStreamingTransformTranslators.java | 32 +++++-
.../flink/FlinkStreamingTranslationContext.java | 14 ++-
.../wrappers/streaming/WorkItemKeySelector.java | 9 +-
.../FlinkStreamingPipelineTranslatorTest.java | 109 +++++++++++++++++++++
.../wrappers/streaming/WindowDoFnOperatorTest.java | 3 +-
6 files changed, 159 insertions(+), 12 deletions(-)
