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

NullPointerException in DateSerializer.

Attach filesAttach ScreenshotVotersWatch issueWatchersCreate sub-taskLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Closed
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 0.9
    • Fix Version/s: 0.10.0
    • Component/s: Runtime / Task
    • Labels:
      None

      Description

      A user reported the following issue to me.

      The data preparation for task 'GroupReduce (GroupReduce at main(XXX.java:96))' , caused an error: Error obtaining the sorted input: Thread 'SortMerger Reading Thread' terminated due to an exception: null
              at org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:472)
              at org.apache.flink.runtime.operators.RegularPactTask.invoke(RegularPactTask.java:362)
              at org.apache.flink.runtime.execution.RuntimeEnvironment.run(RuntimeEnvironment.java:217)
              at java.lang.Thread.run(Thread.java:745)
      Caused by: java.lang.RuntimeException: Error obtaining the sorted input: Thread 'SortMerger Reading Thread' terminated due to an exception: null
              at org.apache.flink.runtime.operators.sort.UnilateralSortMerger.getIterator(UnilateralSortMerger.java:607)
              at org.apache.flink.runtime.operators.RegularPactTask.getInput(RegularPactTask.java:1134)
              at org.apache.flink.runtime.operators.GroupReduceDriver.prepare(GroupReduceDriver.java:94)
              at org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:466)
              ... 3 more
      Caused by: java.io.IOException: Thread 'SortMerger Reading Thread' terminated due to an exception: null
              at org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ThreadBase.run(UnilateralSortMerger.java:785)
      Caused by: java.lang.NullPointerException
              at org.apache.flink.api.common.typeutils.base.DateSerializer.deserialize(DateSerializer.java:72)
              at org.apache.flink.api.common.typeutils.base.DateSerializer.deserialize(DateSerializer.java:28)
              at org.apache.flink.api.java.typeutils.runtime.PojoSerializer.deserialize(PojoSerializer.java:487)
              at org.apache.flink.api.java.typeutils.runtime.TupleSerializer.deserialize(TupleSerializer.java:136)
              at org.apache.flink.api.java.typeutils.runtime.TupleSerializer.deserialize(TupleSerializer.java:30)
              at org.apache.flink.runtime.plugable.ReusingDeserializationDelegate.read(ReusingDeserializationDelegate.java:57)
              at org.apache.flink.runtime.io.network.api.serialization.SpillingAdaptiveSpanningRecordDeserializer.getNextRecord(SpillingAdaptiveSpanningRecordDeserializer.java:111)
              at org.apache.flink.runtime.io.network.api.reader.AbstractRecordReader.getNextRecord(AbstractRecordReader.java:64)
              at org.apache.flink.runtime.io.network.api.reader.MutableRecordReader.next(MutableRecordReader.java:34)
              at org.apache.flink.runtime.operators.util.ReaderIterator.next(ReaderIterator.java:59)
              at org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ReadingThread.go(UnilateralSortMerger.java:1020)
              at org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ThreadBase.run(UnilateralSortMerger.java:781)
      

      I'm investigating it ...

        Attachments

        Issue Links

          Activity

            People

            • Assignee:
              rmetzger Robert Metzger
              Reporter:
              rmetzger Robert Metzger

              Dates

              • Created:
                Updated:
                Resolved:

                Issue deployment