Could you post the stack trace?
Best Regards,
Shixiong Zhu
2014-12-16 23:21 GMT+08:00 richiesgr <richie...@gmail.com>:
>
> Hi
>
> This time I need expert.
> On 1.1.1 and only in cluster (standalone or EC2)
> when I use this code :
>
> countersPublishers.foreachRDD(rdd => {
> rdd.foreachPartition(partitionRecords => {
> partitionRecords.foreach(record => {
> //dbActorUpdater ! updateDBMessage(record)
> println(record)
> })
> })
> })
>
> Get NPP (When I run this locally all is OK)
>
> If I use this
> countersPublishers.foreachRDD(rdd => rdd.collect().foreach(r =>
> dbActorUpdater ! updateDBMessage(r)))
>
> There is no problem. I think something is misconfigured
> Thanks for help
>
>
>
>
> --
> View this message in context:
> http://apache-spark-user-list.1001560.n3.nabble.com/NullPointerException-on-cluster-mode-when-using-foreachPartition-tp20719.html
> Sent from the Apache Spark User List mailing list archive at Nabble.com.
>
> ---------------------------------------------------------------------
> To unsubscribe, e-mail: user-unsubscr...@spark.apache.org
> For additional commands, e-mail: user-h...@spark.apache.org
>
>
