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

NullPointer Exception in JobManager.updateAccumulators

    Details

    • Type: Bug
    • Status: Closed
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 1.2.0, 1.1.4
    • Fix Version/s: 1.2.0, 1.3.0, 1.1.5
    • Component/s: JobManager
    • Labels:
      None

      Description

      NullPointerException
      
      at JobManager$$updateAccumulators$1.apply(JobManager.scala:1790)
      at JobManager$$updateAccumulators$1.apply(JobManager.scala:1788)
      at scala.collection.mutable.ResizableArray$class.forEach(ArrayBuffer.scala:48)
      at scala.collection.mutable.ArrayBuffer.forEach(ArrayBuffer.scala:48)
      at org.apache.flink.runtime.jobmanager.JobManager.org$apache$flink$runtime$jobmanager$JobManager$$updateAccumulators(JobManager.scala:1788)
      at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$1.applyOrElse(JobManager.scala:967)
      at scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:36)
      at org.apache.flink.runtime.LeaderSessionMassageFilter$$anonfun$receive$1.applyOrEslse(LeaderSessionMessageFilter.scala:44)
      at scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:36)
      at org.apache.flink.runtime.LogMessages$$anon$1.apply(LogMessages.scala:33)
      at org.apache.flink.runtime.LogMessages$$anon$1.apply(LogMessages.scala:28)
      at scala.PartialFunction$class.applyOrElse(PartialFunction.scala:123)
      at org.apache.flink.runtime.LogMesages$$anon$1.applyOrElse(LogMessages.scala:28)
      

        Attachments

          Activity

            People

            • Assignee:
              StephanEwen Stephan Ewen
              Reporter:
              StephanEwen Stephan Ewen
            • Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: