[
https://issues.apache.org/jira/browse/FLINK-2336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14620389#comment-14620389
]
Stephan Ewen commented on FLINK-2336:
-------------------------------------
Can you post a simpifies data type that reproduces this problem. Then we can
make a patch to fix this!
> 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)
