This is an automated email from the ASF dual-hosted git repository. zkaoudi pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/incubator-wayang.git
commit be9c4138fc6971401ce98d83125a753098134766 Merge: 5840b1de 54046d65 Author: Zoi Kaoudi <[email protected]> AuthorDate: Mon May 2 15:21:07 2022 +0200 Merge pull request #226 from apache/WAYANG-225 Correction in DistinctOperator for Apache Flink .../org/apache/wayang/flink/compiler/KeySelectorDistinct.java | 3 ++- .../wayang/flink/operators/FlinkDistinctOperatorTest.java | 7 +++---- .../apache/wayang/flink/operators/FlinkJoinOperatorTest.java | 11 ++++++++++- .../wayang/flink/operators/FlinkReduceByOperatorTest.java | 10 +++++++++- 4 files changed, 24 insertions(+), 7 deletions(-)
