When I stop Spark Streaming Context by calling stop(), I always get the 
following error:

ERROR Deregistered receiver for stream 0: Stopped by driver  
class=org.apache.spark.streaming.scheduler.ReceiverTracker
WARN Stopped executor without error  
class=org.apache.spark.streaming.receiver.ReceiverSupervisorImpl
WARN All of the receivers have not deregistered, Map(0 -> 
ReceiverInfo(0,EventReceiver-0,null,false,localhost,Stopped by driver,))  
class=org.apache.spark.streaming.scheduler.ReceiverTracker

Is there a way to avoid these error and warning messages?

Thanks,
-Sing

Reply via email to