spark-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Ted Yu <yuzhih...@gmail.com>
Subject Re: NullPointerException when adding to accumulator
Date Wed, 14 Oct 2015 14:38:21 GMT
Can you show your code snippet with the complete stack trace ?

Thanks

On Wed, Oct 14, 2015 at 7:30 AM, Sela, Amit <ANSELA@paypal.com.invalid>
wrote:

> I'm running a simple streaming application that reads from Kafka, maps the
> events and prints them and I'm trying to use accumulators to count the
> number of mapped records.
>
> While this works in standalone(IDE), when submitting to YARN I get
> NullPointerException on accumulator.add(1) or accumulator += 1
>
> Anyone using accumulators in .map() with Spark 1.5 and YARN ?
>
> Thanks,
> Amit
>
>
>
>

Mime
View raw message