[FLINK-2336] ArrayIndexOufOBoundsException in TypeExtractor when mapping

• Type: Bug
• Status: Closed
• Priority: Critical
• Resolution: Fixed
• Affects Version/s: 0.10.0
• Fix Version/s: 1.10.1, 1.11.0
• Component/s: API / Type Serialization System
• Labels: pull-request-available usability
• Assignee: Guowei Ma
• Reporter: William Saar
• Created: 09/Jul/15 11:25
• Updated: 05/Mar/20 09:10
• Resolved: 05/Mar/20 09:10

Description

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)

Issue Links

• links to: GitHub Pull Request #11234