[FLINK-5585] NullPointer Exception in JobManager.updateAccumulators

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.1.4, 1.2.0
• Fix Version/s: 1.1.5, 1.2.0, 1.3.0
• Component/s: Runtime / Coordination
• Assignee: Stephan Ewen
• Reporter: Stephan Ewen
• Created: 20/Jan/17 10:12
• Updated: 28/Feb/19 14:01
• Resolved: 20/Jan/17 18:29

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)