flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Dave Marion <dlmar...@comcast.net>
Subject NPE in JobManager
Date Thu, 19 Jan 2017 16:57:06 GMT
I'm running flink-1.1.4-bin-hadoop27-scala_2.11 and I'm running into an issue where after some
period of time (measured in 1 - 3 hours) the JobManager gets an NPE and shuts itself down.
The failure is at JobManager$$updateAccumulators$1.apply(JobManager.scala:1790). I'm using
a custom accumulator[1], but can't tell from the JobManager code whether the issue is in my
Accumulator, or is a bug in the JobManager.


[1] https://github.com/NationalSecurityAgency/timely/blob/master/analytics/src/main/java/timely/analytics/flink/SortedStringAccumulator.java

Mime
View raw message