Hi all,

In Spark Streaming, when I do "foreachRDD" on my DStreams, I get a
NonSerializable exception when I try to do something like:

DStream.foreachRDD( rdd => {
  var sc.parallelize(Seq(("test", "blah")))
})

Is there any way around that ?

Thanks,

Harold

Reply via email to