Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-2336

ArrayIndexOufOBoundsException in TypeExtractor when mapping

    XMLWordPrintableJSON

    Details

      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)

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                maguowei Guowei Ma
                Reporter:
                william William Saar
              • Votes:
                0 Vote for this issue
                Watchers:
                8 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved:

                  Time Tracking

                  Estimated:
                  Original Estimate - Not Specified
                  Not Specified
                  Remaining:
                  Remaining Estimate - 0h
                  0h
                  Logged:
                  Time Spent - 20m
                  20m