Can you pastebin the complete stack trace for the NPE ? Thanks
On Thu, Jan 19, 2017 at 8:57 AM, Dave Marion <dlmar...@comcast.net> wrote: > 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 >
