flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From aljos...@apache.org
Subject [06/10] flink git commit: [hotfix] Use own SumReducer in WindowOperatorMigrationTest
Date Mon, 23 Jan 2017 14:01:46 GMT
[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/8fcd26b7
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/8fcd26b7
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/8fcd26b7

Branch: refs/heads/release-1.2
Commit: 8fcd26b7e881cf4901d30cd37c4de8925b59e985
Parents: e3bab4a
Author: Aljoscha Krettek <aljoscha.krettek@gmail.com>
Authored: Thu Jan 12 18:54:38 2017 +0100
Committer: Aljoscha Krettek <aljoscha.krettek@gmail.com>
Committed: Mon Jan 23 14:53:22 2017 +0100

----------------------------------------------------------------------
 .../operators/windowing/WindowOperatorMigrationTest.java     | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/8fcd26b7/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<>(


Mime
View raw message