JobScheduler.start() has thrown a SparkException

We found this prefix in 2 webpages.
MapChildren (2)Typical messages (2)TraceDetailed Map
  1. org.apache.spark.SparkException
    1.   at org.apache.spark.streaming.dstream.DStream.isTimeValid()
    2.   at org.apache.spark.streaming.dstream.InputDStream.isTimeValid()
    3.   at org.apache.spark.streaming.dstream.DStream$$anonfun$getOrCompute$1.apply()
    4.   at org.apache.spark.streaming.dstream.DStream$$anonfun$getOrCompute$1.apply()
    5.   at scala.Option.orElse()
    6.   at org.apache.spark.streaming.dstream.DStream.getOrCompute()
    7.   at org.apache.spark.streaming.dstream.ForEachDStream.generateJob()
    8.   at org.apache.spark.streaming.DStreamGraph$$anonfun$1.apply()
    9.   at org.apache.spark.streaming.DStreamGraph$$anonfun$1.apply()
    10.   at scala.collection.TraversableLike$$anonfun$flatMap$1.apply()
    11.   at scala.collection.TraversableLike$$anonfun$flatMap$1.apply()
    12.   at scala.collection.mutable.ResizableArray$class.foreach()
    13.   at scala.collection.mutable.ArrayBuffer.foreach()
    14.   at scala.collection.TraversableLike$class.flatMap()
    15.   at scala.collection.AbstractTraversable.flatMap()
    16.   at org.apache.spark.streaming.DStreamGraph.generateJobs()
    17.   at org.apache.spark.streaming.scheduler.JobGenerator$$anonfun$restart$4.apply()
    18.   at org.apache.spark.streaming.scheduler.JobGenerator$$anonfun$restart$4.apply()
    19.   at scala.collection.IndexedSeqOptimized$class.foreach()
    20.   at scala.collection.mutable.ArrayOps$ofRef.foreach()
    21.   at org.apache.spark.streaming.scheduler.JobGenerator.restart()
    22.   at org.apache.spark.streaming.scheduler.JobGenerator.start()
    23.   at org.apache.spark.streaming.scheduler.JobScheduler.start()
loading...
  1. Apache Spark Developers List - DStream not initialized SparkException

    First:2 years ago
    Last:2 years ago
  2. DirectKafkaInputDStream has not been initialized when recovery from checkpoint

    First:3 years ago
    Last:2 years ago
    Author:yangping wu
    Site:Apache's JIRA Issue Tracker
    http://issues.apache.org/jira/browse/SPARK-6770
MessageNumber of crashes
org.apache.spark.streaming.kafka.DirectKafkaInputDStream@41a80e5a has not been initialized1
org.apache.spark.streaming.kafka.DirectKafkaInputDStream@15ce2c0 has not been initialized1
  1. org.apache.spark.SparkException
    1.   at org.apache.spark.streaming.dstream.DStream.isTimeValid()
    2.   at org.apache.spark.streaming.dstream.InputDStream.isTimeValid()
    3.   at org.apache.spark.streaming.dstream.DStream$$anonfun$getOrCompute$1.apply()
    4.   at org.apache.spark.streaming.dstream.DStream$$anonfun$getOrCompute$1.apply()
    5.   at scala.Option.orElse()
    6.   at org.apache.spark.streaming.dstream.DStream.getOrCompute()
    7.   at org.apache.spark.streaming.dstream.ForEachDStream.generateJob()
    8.   at org.apache.spark.streaming.DStreamGraph$$anonfun$1.apply()
    9.   at org.apache.spark.streaming.DStreamGraph$$anonfun$1.apply()
    10.   at scala.collection.TraversableLike$$anonfun$flatMap$1.apply()
    11.   at scala.collection.TraversableLike$$anonfun$flatMap$1.apply()
    12.   at scala.collection.mutable.ResizableArray$class.foreach()
    13.   at scala.collection.mutable.ArrayBuffer.foreach()
    14.   at scala.collection.TraversableLike$class.flatMap()
    15.   at scala.collection.AbstractTraversable.flatMap()
    16.   at org.apache.spark.streaming.DStreamGraph.generateJobs()
    17.   at org.apache.spark.streaming.scheduler.JobGenerator$$anonfun$restart$4.apply()
    18.   at org.apache.spark.streaming.scheduler.JobGenerator$$anonfun$restart$4.apply()
    19.   at scala.collection.IndexedSeqOptimized$class.foreach()
    20.   at scala.collection.mutable.ArrayOps$ofRef.foreach()
    21.   at org.apache.spark.streaming.scheduler.JobGenerator.restart()
    22.   at org.apache.spark.streaming.scheduler.JobGenerator.start()
    23.   at org.apache.spark.streaming.scheduler.JobScheduler.start()
loading...