[jira] [Created] (FLINK-2336) ArrayIndexOufOBoundsException in TypeExtractor when mapping

[Shang Yuanchun (Jira)]

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)