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
