java.lang.IllegalStateException: Adding new inputs, transformations, and output operations after stopping a context is not supported


Solutions on the web9

Solution icon of web
Adding new inputs, transformations, and output operations after stopping a context is not supported

Solution icon of web
via gmane.org by Unknown author, 1 year ago
Adding new inputs, transformations, and output operations after stopping a context is not supported

Solution icon of stackoverflow
Adding new inputs, transformations, and output operations after stopping a context is not supported

Solution icon of stackoverflow
Adding new inputs, transformations, and output operations after stopping a context is not supported

Solution icon of stackoverflow
Adding new inputs, transformations, and output operations after starting a context is not supported

Solution icon of web
via codegur.com by Unknown author, 1 year ago
Adding new inputs, transformations, and output operations after sta$ ting a context is not supported

Solution icon of stackoverflow
Adding new inputs, transformations, and output operations after starting a context is not supported

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

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

Stack trace

java.lang.IllegalStateException: Adding new inputs, transformations, and output operations after stopping a context is not supported
	at org.apache.spark.streaming.dstream.DStream.validateAtInit(DStream.scala:224)
	at org.apache.spark.streaming.dstream.DStream.<init>(DStream.scala:64)
	at org.apache.spark.streaming.dstream.ForEachDStream.<init>(ForEachDStream.scala:26)
	at org.apache.spark.streaming.dstream.DStream$$anonfun$foreachRDD$2.apply(DStream.scala:642)
	at org.apache.spark.streaming.dstream.DStream$$anonfun$foreachRDD$2.apply(DStream.scala:642)
	at org.apache.spark.rdd.RDDOperationScope$.withScope(RDDOperationScope.scala:148)
	at org.apache.spark.rdd.RDDOperationScope$.withScope(RDDOperationScope.scala:109)
	at org.apache.spark.SparkContext.withScope(SparkContext.scala:681)
	at org.apache.spark.streaming.StreamingContext.withScope(StreamingContext.scala:258)
	at org.apache.spark.streaming.dstream.DStream.foreachRDD(DStream.scala:638)
	at org.apache.spark.streaming.dstream.DStream$$anonfun$foreachRDD$1.apply$mcV$sp(DStream.scala:631)
	at org.apache.spark.streaming.dstream.DStream$$anonfun$foreachRDD$1.apply(DStream.scala:629)
	at org.apache.spark.streaming.dstream.DStream$$anonfun$foreachRDD$1.apply(DStream.scala:629)
	at org.apache.spark.rdd.RDDOperationScope$.withScope(RDDOperationScope.scala:148)
	at org.apache.spark.rdd.RDDOperationScope$.withScope(RDDOperationScope.scala:109)
	at org.apache.spark.SparkContext.withScope(SparkContext.scala:681)
	at org.apache.spark.streaming.StreamingContext.withScope(StreamingContext.scala:258)
	at org.apache.spark.streaming.dstream.DStream.foreachRDD(DStream.scala:629)
	at org.apache.spark.streaming.api.java.JavaDStreamLike$class.foreachRDD(JavaDStreamLike.scala:315)
	at org.apache.spark.streaming.api.java.AbstractJavaDStreamLike.foreachRDD(JavaDStreamLike.scala:43)
	at com.til.ibeat.script.AggregateDashboardDataKafka$5.run(AggregateDashboardDataKafka.java:210)

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

Samebug visitor profile picture
Unknown user
Once, 1 year ago