Searched on Google with the first line of a JAVA stack trace?

We can recommend more relevant solutions and speed up debugging when you paste your entire stack trace with the exception message. Try a sample exception.

Recommended solutions based on your search

Solutions on the web

via Apache's JIRA Issue Tracker by yangping wu, 1 year ago
org.apache.spark.streaming.kafka.DirectKafkaInputDStream@41a80e5a has not been initialized
via nabble.com by Unknown author, 1 year ago
org.apache.spark.streaming.kafka.DirectKafkaInputDStream@15ce2c0 has not been initialized
via Stack Overflow by Sadaf
, 1 year ago
org.apache.spark.streaming.dstream.WindowedDStream@532d0784 has not been initialized
via Stack Overflow by alarius
, 1 year ago
org.apache.spark.streaming.dstream.ReducedWindowedDStream@65600fb3 has not been initialized
via Stack Overflow by Amit_Hora
, 1 year ago
org.apache.spark.streaming.dstream.ShuffledDStream@1d304ac has not been initialized
org.apache.spark.SparkException: org.apache.spark.streaming.kafka.DirectKafkaInputDStream@41a80e5a has not been initialized	at org.apache.spark.streaming.dstream.DStream.isTimeValid(DStream.scala:266)	at org.apache.spark.streaming.dstream.InputDStream.isTimeValid(InputDStream.scala:51)	at org.apache.spark.streaming.dstream.DStream$$anonfun$getOrCompute$1.apply(DStream.scala:287)	at org.apache.spark.streaming.dstream.DStream$$anonfun$getOrCompute$1.apply(DStream.scala:287)	at scala.Option.orElse(Option.scala:257)	at org.apache.spark.streaming.dstream.DStream.getOrCompute(DStream.scala:284)	at org.apache.spark.streaming.dstream.ForEachDStream.generateJob(ForEachDStream.scala:38)	at org.apache.spark.streaming.DStreamGraph$$anonfun$1.apply(DStreamGraph.scala:116)	at org.apache.spark.streaming.DStreamGraph$$anonfun$1.apply(DStreamGraph.scala:116)	at scala.collection.TraversableLike$$anonfun$flatMap$1.apply(TraversableLike.scala:251)	at scala.collection.TraversableLike$$anonfun$flatMap$1.apply(TraversableLike.scala:251)	at scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:59)	at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:47)	at scala.collection.TraversableLike$class.flatMap(TraversableLike.scala:251)	at scala.collection.AbstractTraversable.flatMap(Traversable.scala:105)	at org.apache.spark.streaming.DStreamGraph.generateJobs(DStreamGraph.scala:116)	at org.apache.spark.streaming.scheduler.JobGenerator$$anonfun$restart$4.apply(JobGenerator.scala:223)	at org.apache.spark.streaming.scheduler.JobGenerator$$anonfun$restart$4.apply(JobGenerator.scala:218)	at scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:33)	at scala.collection.mutable.ArrayOps$ofRef.foreach(ArrayOps.scala:108)	at org.apache.spark.streaming.scheduler.JobGenerator.restart(JobGenerator.scala:218)	at org.apache.spark.streaming.scheduler.JobGenerator.start(JobGenerator.scala:89)	at org.apache.spark.streaming.scheduler.JobScheduler.start(JobScheduler.scala:67)	at org.apache.spark.streaming.StreamingContext.start(StreamingContext.scala:512)	at logstatstreaming.UserChannelTodb$.main(UserChannelTodb.scala:57)	at logstatstreaming.UserChannelTodb.main(UserChannelTodb.scala)	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)	at java.lang.reflect.Method.invoke(Method.java:597)	at org.apache.spark.deploy.SparkSubmit$.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:569)	at org.apache.spark.deploy.SparkSubmit$.doRunMain$1(SparkSubmit.scala:166)	at org.apache.spark.deploy.SparkSubmit$.submit(SparkSubmit.scala:189)	at org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:110)	at org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala)