[hotfix] Use own SumReducer in WindowOperatorMigrationTest
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5461b95e Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/5461b95e Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/5461b95e Branch: refs/heads/master Commit: 5461b95ee3c46812cedc59ad738e0d7a56c1f728 Parents: 6b55e2c Author: Aljoscha Krettek <[email protected]> Authored: Thu Jan 12 18:54:38 2017 +0100 Committer: Aljoscha Krettek <[email protected]> Committed: Tue Jan 24 10:42:34 2017 +0100 ---------------------------------------------------------------------- .../operators/windowing/WindowOperatorMigrationTest.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/5461b95e/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperatorMigrationTest.java ---------------------------------------------------------------------- diff --git a/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperatorMigrationTest.java b/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperatorMigrationTest.java index b7d5928..429ffbe 100644 --- a/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperatorMigrationTest.java +++ b/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperatorMigrationTest.java @@ -424,7 +424,7 @@ public class WindowOperatorMigrationTest { TypeInformation<Tuple2<String, Integer>> inputType = TypeInfoParser.parse("Tuple2<String, Integer>"); ReducingStateDescriptor<Tuple2<String, Integer>> stateDesc = new ReducingStateDescriptor<>("window-contents", - new WindowOperatorTest.SumReducer(), + new SumReducer(), inputType.createSerializer(new ExecutionConfig())); WindowOperator<String, Tuple2<String, Integer>, Tuple2<String, Integer>, Tuple2<String, Integer>, TimeWindow> operator = new WindowOperator<>( @@ -508,7 +508,7 @@ public class WindowOperatorMigrationTest { new TupleKeySelector(), BasicTypeInfo.STRING_TYPE_INFO.createSerializer(new ExecutionConfig()), stateDesc, - new InternalIterableWindowFunction<>(new WindowOperatorTest.RichSumReducer<TimeWindow>()), + new InternalIterableWindowFunction<>(new RichSumReducer<TimeWindow>()), ProcessingTimeTrigger.create(), 0); @@ -621,7 +621,7 @@ public class WindowOperatorMigrationTest { TypeInformation<Tuple2<String, Integer>> inputType = TypeInfoParser.parse("Tuple2<String, Integer>"); ReducingStateDescriptor<Tuple2<String, Integer>> stateDesc = new ReducingStateDescriptor<>("window-contents", - new WindowOperatorTest.SumReducer(), + new SumReducer(), inputType.createSerializer(new ExecutionConfig())); WindowOperator<String, Tuple2<String, Integer>, Tuple2<String, Integer>, Tuple2<String, Integer>, TimeWindow> operator = new WindowOperator<>( @@ -723,7 +723,7 @@ public class WindowOperatorMigrationTest { TypeInformation<Tuple2<String, Integer>> inputType = TypeInfoParser.parse("Tuple2<String, Integer>"); ReducingStateDescriptor<Tuple2<String, Integer>> stateDesc = new ReducingStateDescriptor<>("window-contents", - new WindowOperatorTest.SumReducer(), + new SumReducer(), inputType.createSerializer(new ExecutionConfig())); WindowOperator<String, Tuple2<String, Integer>, Tuple2<String, Integer>, Tuple2<String, Integer>, TimeWindow> operator = new WindowOperator<>(
