Re: Spark Streaming checkpoint recovery throws Stack Overflow Error

2015-09-18 Thread Saisai Shao
tream$$anonfun$getOrCompute$1$$anonfun$1.apply(DStream.scala:349) >> at >> >> org.apache.spark.streaming.dstream.DStream$$anonfun$getOrCompute$1$$anonfun$1.apply(DStream.scala:349) >> at >> >> org.apache.spark.streaming.dstream.DStream.createRDDWithLocalPrope

Spark Streaming checkpoint recovery throws Stack Overflow Error

2015-09-18 Thread swetha
$1.apply(DStream.scala:342) at scala.Option.orElse(Option.scala:257) -- View this message in context: http://apache-spark-user-list.1001560.n3.nabble.com/Spark-Streaming-checkpoint-recovery-throws-Stack-Overflow-Error-tp24737.html Sent from the Apache Spark User List mailing list

Re: Spark Streaming checkpoint recovery throws Stack Overflow Error

2015-09-18 Thread Ted Yu
e$1$$anonfun$1.apply(DStream.scala:349) > at > > org.apache.spark.streaming.dstream.DStream.createRDDWithLocalProperties(DStream.scala:399) > at > > org.apache.spark.streaming.dstream.DStream$$anonfun$getOrCompute$1.apply(DStream.scala:344) > at > > org.apache.spark.streaming.dstream.DStream$