Not sure I can help, but I ran into the same problem. Basically my use case is a that I have a List of strings - which I then convert into a RDD using sc.parallelize(). This RDD is then operated on by the foreach() function. Same as you, I get a runtime exception :
java.lang.ClassCastException: cannot assign instance of rickshaw.spark.transformations.AssetFunction to field org.apache.spark.api.java.JavaRDDLike$$anonfun$1.f$14 of type org.apache.spark.api.java.function.VoidFunction in instance of org.apache.spark.api.java.JavaRDDLike$$anonfun$1 ----- -- View this message in context: http://apache-spark-user-list.1001560.n3.nabble.com/getting-ClassCastException-on-collect-tp8054p9798.html Sent from the Apache Spark User List mailing list archive at Nabble.com.
