Spark Streaming error in zeppelin paragraph: java.lang.NoClassDefFoundError:

[afancy]

Dear all,

I pull  zeppelin from github, and  build. I run the following Spark
streaming code in a paragraph, but got the NoClassDefFoundError. Could
anybody help? thanks!

import org.apache.spark._
import org.apache.spark.streaming._
import org.apache.spark.streaming.StreamingContext._


case class Loc(lat: Double, lon: Double)
case class message(info: String, loc: Loc)

val ssc = new StreamingContext(sc, Seconds(5))
val input = ssc.socketTextStream("localhost", 12397)


input.foreachRDD(rdd => {
    val df = rdd.map(s => message(
                          s.info,
                          Loc(s.lat, s.lon)
                      )
                    )

    var items = df.collect
    z.angularBind("locations", items)
})

ssc.start()


import org.apache.spark._
import org.apache.spark.streaming._
import org.apache.spark.streaming.StreamingContext._
defined class Loc
defined class message
ssc: org.apache.spark.streaming.StreamingContext =
org.apache.spark.streaming.StreamingContext@657c0ac3
java.lang.NoClassDefFoundError: Could not initialize class
org.apache.spark.rdd.RDDOperationScope$
at
org.apache.spark.streaming.StreamingContext.withNamedScope(StreamingContext.scala:273)
at
org.apache.spark.streaming.StreamingContext.socketTextStream(StreamingContext.scala:301)
... 100 elided