It's hard to tell without more info. >From the method that threw the exception it looked like it was trying to deserialize the accumulator. By any chance did you change your accumulator class but forgot to update the serialVersionUID? Just wondering if it is trying to deserialize to a different class definition.
A more detailed stscktrace (maybe with debug on) will help. Tim On Tue, Jun 4, 2019, 8:41 PM Vishal Santoshi <vishal.santo...@gmail.com> wrote: > I see tons of > > org.apache.flink.runtime.executiongraph.ExecutionGraph - Cannot > update accumulators for job 7bfe57bb0ed1c5c2f4f40c2fccaab50d. > > java.lang.NullPointerException > > > > > https://github.com/apache/flink/blob/master/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java#L1715 > > Not sure why it is tagged ERROR and the pipe does not abort or what this > implies..... >
