diff --git a/flink-optimizer/src/test/java/org/apache/flink/optimizer/custompartition/GroupingKeySelectorTranslationTest.java b/flink-optimizer/src/test/java/org/apache/flink/optimizer/custompartition/GroupingKeySelectorTranslationTest.java index b2bfc67365a49f0824cd0fb2d39e8cf33bda3111..40e72524a27f073818993518c0bf7719fb45c21b 100644 --- a/flink-optimizer/src/test/java/org/apache/flink/optimizer/custompartition/GroupingKeySelectorTranslationTest.java +++ b/flink-optimizer/src/test/java/org/apache/flink/optimizer/custompartition/GroupingKeySelectorTranslationTest.java @@ -34,7 +34,7 @@ import org.apache.flink.api.java.tuple.Tuple3; import org.apache.flink.optimizer.plan.OptimizedPlan; import org.apache.flink.optimizer.plan.SingleInputPlanNode; import org.apache.flink.optimizer.plan.SinkPlanNode; -import org.apache.flink.optimizer.testfunctions.DummyReducer; +import org.apache.flink.optimizer.testfunctions.SelectOneReducer; import org.apache.flink.optimizer.testfunctions.IdentityGroupReducerCombinable; import org.apache.flink.optimizer.util.CompilerTestBase; import org.apache.flink.runtime.operators.shipping.ShipStrategyType; @@ -53,7 +53,7 @@ public class GroupingKeySelectorTranslationTest extends CompilerTestBase { data.groupBy(new TestKeySelector>()) .withPartitioner(new TestPartitionerInt()) - .reduce(new DummyReducer>()) + .reduce(new SelectOneReducer>()) .output(new DiscardingOutputFormat>()); Plan p = env.createProgramPlan(); diff --git a/flink-optimizer/src/test/java/org/apache/flink/optimizer/custompartition/GroupingPojoTranslationTest.java b/flink-optimizer/src/test/java/org/apache/flink/optimizer/custompartition/GroupingPojoTranslationTest.java index dc2b14767063cc464c5fed23f6d8b950d8232835..52bf9dd4f4a2e9188f6f209699ec249432a3d76f 100644 --- a/flink-optimizer/src/test/java/org/apache/flink/optimizer/custompartition/GroupingPojoTranslationTest.java +++ b/flink-optimizer/src/test/java/org/apache/flink/optimizer/custompartition/GroupingPojoTranslationTest.java @@ -30,7 +30,7 @@ import org.apache.flink.api.java.io.DiscardingOutputFormat; import org.apache.flink.optimizer.plan.OptimizedPlan; import org.apache.flink.optimizer.plan.SingleInputPlanNode; import org.apache.flink.optimizer.plan.SinkPlanNode; -import org.apache.flink.optimizer.testfunctions.DummyReducer; +import org.apache.flink.optimizer.testfunctions.SelectOneReducer; import org.apache.flink.optimizer.testfunctions.IdentityGroupReducerCombinable; import org.apache.flink.optimizer.util.CompilerTestBase; import org.apache.flink.runtime.operators.shipping.ShipStrategyType; @@ -48,7 +48,7 @@ public class GroupingPojoTranslationTest extends CompilerTestBase { .rebalance().setParallelism(4); data.groupBy("a").withPartitioner(new TestPartitionerInt()) - .reduce(new DummyReducer()) + .reduce(new SelectOneReducer()) .output(new DiscardingOutputFormat()); Plan p = env.createProgramPlan(); @@ -255,4 +255,4 @@ public class GroupingPojoTranslationTest extends CompilerTestBase { return 0; } } -} \ No newline at end of file +} diff --git a/flink-optimizer/src/test/java/org/apache/flink/optimizer/custompartition/GroupingTupleTranslationTest.java b/flink-optimizer/src/test/java/org/apache/flink/optimizer/custompartition/GroupingTupleTranslationTest.java index 6eb5ad5de214c5fd7f5ceaca7cd00ba97d1d9a26..88b15994a5bf1d8ea56ad6e43e4c8f3ed0cd5f2f 100644 --- a/flink-optimizer/src/test/java/org/apache/flink/optimizer/custompartition/GroupingTupleTranslationTest.java +++ b/flink-optimizer/src/test/java/org/apache/flink/optimizer/custompartition/GroupingTupleTranslationTest.java @@ -33,7 +33,7 @@ import org.apache.flink.api.java.tuple.Tuple4; import org.apache.flink.optimizer.plan.OptimizedPlan; import org.apache.flink.optimizer.plan.SingleInputPlanNode; import org.apache.flink.optimizer.plan.SinkPlanNode; -import org.apache.flink.optimizer.testfunctions.DummyReducer; +import org.apache.flink.optimizer.testfunctions.SelectOneReducer; import org.apache.flink.optimizer.testfunctions.IdentityGroupReducerCombinable; import org.apache.flink.optimizer.util.CompilerTestBase; import org.apache.flink.runtime.operators.shipping.ShipStrategyType; @@ -80,7 +80,7 @@ public class GroupingTupleTranslationTest extends CompilerTestBase { .rebalance().setParallelism(4); data.groupBy(0).withPartitioner(new TestPartitionerInt()) - .reduce(new DummyReducer>()) + .reduce(new SelectOneReducer>()) .output(new DiscardingOutputFormat>()); Plan p = env.createProgramPlan(); diff --git a/flink-optimizer/src/test/java/org/apache/flink/optimizer/testfunctions/DummyReducer.java b/flink-optimizer/src/test/java/org/apache/flink/optimizer/testfunctions/DummyReducer.java deleted file mode 100644 index 44d369528e107aa0bf0438d81153276b8797fa13..0000000000000000000000000000000000000000 --- a/flink-optimizer/src/test/java/org/apache/flink/optimizer/testfunctions/DummyReducer.java +++ /dev/null @@ -1,31 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package org.apache.flink.optimizer.testfunctions; - -import org.apache.flink.api.common.functions.RichReduceFunction; - -public class DummyReducer extends RichReduceFunction { - - private static final long serialVersionUID = 1L; - - @Override - public T reduce(T a, T b) { - return a; - } -}