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
