[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 <[email protected]> Authored: Tue Dec 13 11:05:50 2016 +0100 Committer: Aljoscha Krettek <[email protected]> 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); }
