William Saar created FLINK-2336:
-----------------------------------
Summary: ArrayIndexOufOBoundsException in TypeExtractor when
mapping
Key: FLINK-2336
URL: https://issues.apache.org/jira/browse/FLINK-2336
Project: Flink
Issue Type: Bug
Affects Versions: master
Reporter: William Saar
The line that causes this is
DataStream<O> outputStream = insideIterationStream.filter(outputFilter).map(m
-> m.outputMessage);
Problem occurs both when compiled using Javac and Eclipse's JDT compiler (in an
environment where simple lambda type tests work)
Exception in thread "main" java.lang.ArrayIndexOutOfBoundsException: -1
at java.util.ArrayList.elementData(Unknown Source)
at java.util.ArrayList.get(Unknown Source)
at
org.apache.flink.api.java.typeutils.TypeExtractor.createTypeInfoFromInputs(TypeExtractor.java:553)
at
org.apache.flink.api.java.typeutils.TypeExtractor.createTypeInfoWithTypeHierarchy(TypeExtractor.java:468)
at
org.apache.flink.api.java.typeutils.TypeExtractor.privateCreateTypeInfo(TypeExtractor.java:370)
at
org.apache.flink.api.java.typeutils.TypeExtractor.getUnaryOperatorReturnType(TypeExtractor.java:254)
at
org.apache.flink.api.java.typeutils.TypeExtractor.getMapReturnTypes(TypeExtractor.java:91)
at
org.apache.flink.streaming.api.datastream.DataStream.map(DataStream.java:605)
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
