Based on where this line of code is, it is hard to get the full stack
trace, as in the
LOG.error("Cannot update accumulators for job {}.", getJobID(), e);
does not get us the full stack trace....
Though it is true that the Accumulator did not have a serialVersionUID. I
would double check. I though would think this should not be a recoverable
error ?
On Tue, Jun 4, 2019 at 4:32 PM Timothy Victor <[email protected]> wrote:
> 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 <[email protected]>
> 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.....
>>
>
