[GitHub] [beam] mxm commented on a change in pull request #13353: [BEAM-11267] Remove unnecessary reshuffle for stateful ParDo after key…

2020-11-17 Thread GitBox
mxm commented on a change in pull request #13353: URL: https://github.com/apache/beam/pull/13353#discussion_r524634584 ## File path: runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkStreamingTransformTranslators.java ## @@ -971,7 +987,9 @@ public void

[GitHub] [beam] mxm commented on a change in pull request #13353: [BEAM-11267] Remove unnecessary reshuffle for stateful ParDo after key…

2020-11-16 Thread GitBox
mxm commented on a change in pull request #13353: URL: https://github.com/apache/beam/pull/13353#discussion_r524634584 ## File path: runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkStreamingTransformTranslators.java ## @@ -971,7 +987,9 @@ public void