Would really like an answer to this. A `yes` or `no` would suffice. I'm talking ab RDD failure in this context: myStream.foreachRDD(rdd=>rdd.foreach(tuple => println(tuple)))
From: Adrian Mocanu [mailto:[email protected]] Sent: February-27-14 12:19 PM To: [email protected] Subject: is RDD failure transparent to stream consumer Is RDD failure transparent to a spark stream consumer except for the slowdown needed to recreate the RDD. After reading the papers on RDDs and DStreams from spark homepage I believe it is, but I'd like a confirmation. Thanks -Adrian
