java.lang.IllegalStateException

Adding new inputs, transformations, and output operations after sta$ ting a context is not supported

Samebug tips0

We couldn't find tips for this exception.

Don't give up yet. Paste your full stack trace to get a solution.

Solutions on the web8

  • via Unknown by Unknown author,
  • Stack trace

    • java.lang.IllegalStateException: Adding new inputs, transformations, and output operations after sta$ ting a context is not supported at org.apache.spark.streaming.dstream.DStream.validateAtInit(DStream.scala:222) at org.apache.spark.streaming.dstream.DStream.<init>(DStream.scala:64) at org.apache.spark.streaming.dstream.ForEachDStream.<init>(ForEachDStream.scala:34) at org.apache.spark.streaming.dstream.DStream.org$apache$spark$streaming$dstream$DStream$$foreachRDD(DStream.scala:687) at org.apache.spark.streaming.dstream.DStream$$anonfun$foreachRDD$1.apply$mcV$sp(DStream.scala:661) at org.apache.spark.streaming.dstream.DStream$$anonfun$foreachRDD$1.apply(DStream.scala:659) at org.apache.spark.streaming.dstream.DStream$$anonfun$foreachRDD$1.apply(DStream.scala:659) at org.apache.spark.rdd.RDDOperationScope$.withScope(RDDOperationScope.scala:150) at org.apache.spark.rdd.RDDOperationScope$.withScope(RDDOperationScope.scala:111) at org.apache.spark.SparkContext.withScope(SparkContext.scala:714) at org.apache.spark.streaming.StreamingContext.withScope(StreamingContext.scala:260) at org.apache.spark.streaming.dstream.DStream.foreachRDD(DStream.scala:659) at main.scala.feaUS.Listener.run(feaUS.scala:119) at java.lang.Thread.run(Thread.java:745)

    Write tip

    You have a different solution? A short tip here would help you and many other users who saw this issue last week.

    Users with the same issue

    Unknown visitor
    Unknown visitorOnce,