scala - Spark NullPointerException inside foreach loop -



scala - Spark NullPointerException inside foreach loop -

i have rdd , want loop on it. this:

pointsmap.foreach({ p => val pointswithcoordinateswithdistance = pointsmap.leftouterjoin(xcoordinateswithdistance) pointswithcoordinateswithdistance.foreach(println) println("---") })

however, nullpointerexception occuring:

java.lang.nullpointerexception @ org.apache.spark.rdd.rdd.<init>(rdd.scala:125) @ org.apache.spark.rdd.cogroupedrdd.<init>(cogroupedrdd.scala:69) @ org.apache.spark.rdd.pairrddfunctions.cogroup(pairrddfunctions.scala:651) @ org.apache.spark.rdd.pairrddfunctions.leftouterjoin(pairrddfunctions.scala:483) @ org.apache.spark.rdd.pairrddfunctions.leftouterjoin(pairrddfunctions.scala:555) ...

both pointsmap , xcoordinateswithdistance initialized before foreach , contain elements. not within foreach loop leftouterjoin works. total version of code please see https://github.com/timasjov/spark-learning/blob/master/src/dbscan.scala

don't utilize rdd in function of rdd operator. need utilize proper rdd operators when want manipulate more 1 rdds together, such join.

scala foreach nullpointerexception apache-spark rdd

Comments

Popular posts from this blog

formatting - SAS SQL Datepart function returning odd values -

c++ - Apple Mach-O Linker Error(Duplicate Symbols For Architecture armv7) -

php - Yii 2: Unable to find a class into the extension 'yii2-admin' -