flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From aljos...@apache.org
Subject [6/6] flink git commit: [FLINK-5320] Fix result TypeInformation in WindowedStream.fold
Date Wed, 11 Jan 2017 11:15:51 GMT
[FLINK-5320] Fix result TypeInformation in WindowedStream.fold


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/274cc41a
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/274cc41a
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/274cc41a

Branch: refs/heads/master
Commit: 274cc41a6a43e95243d6e7b3110e16ff6f0ad633
Parents: 2af939a
Author: Yassine Marzougui <y.marzougui@mindlytix.com>
Authored: Tue Dec 13 11:05:50 2016 +0100
Committer: Aljoscha Krettek <aljoscha.krettek@gmail.com>
Committed: Wed Jan 11 10:35:47 2017 +0100

----------------------------------------------------------------------
 .../org/apache/flink/streaming/api/datastream/WindowedStream.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/274cc41a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/WindowedStream.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/WindowedStream.java
b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/WindowedStream.java
index a18a59c..e2f930a 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/WindowedStream.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/WindowedStream.java
@@ -389,7 +389,7 @@ public class WindowedStream<T, K, W extends Window> {
 			Utils.getCallLocationName(), true);
 
 		TypeInformation<R> resultType = TypeExtractor.getUnaryOperatorReturnType(
-			function, WindowFunction.class, true, true, getInputType(), null, false);
+			function, WindowFunction.class, true, true, foldAccumulatorType, null, false);
 
 		return fold(initialValue, foldFunction, function, foldAccumulatorType, resultType);
 	}


Mime
View raw message