Has anybody seen this behavior (see tha attached picture) in Spark
Streaming?
It started to happen here after I changed the HiveContext creation to
stream.foreachRDD {
rdd =>
val hiveContext = new HiveContext(rdd.sparkContext)
}Is this expected? Kind Regards, Dirceu
--------------------------------------------------------------------- To unsubscribe e-mail: dev-unsubscr...@spark.apache.org
