[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/ebc13884 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ebc13884 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/ebc13884 Branch: refs/heads/release-1.2 Commit: ebc138841f8f890d47a590496459a0f6f7609d4b Parents: 6aa38ee Author: Yassine Marzougui <[email protected]> Authored: Tue Dec 13 11:05:50 2016 +0100 Committer: Aljoscha Krettek <[email protected]> Committed: Wed Jan 11 15:47:30 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/ebc13884/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 98bf89a..288889c 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); }
