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
Post a Comment