KafkaReciever Error when starting ssc (Actor name not unique)

[gaganbm <ga...@gmail.com>]

Hi All,

I am getting this exception when doing ssc.start to start the streaming
context.


ERROR KafkaReceiver - Error receiving data
akka.actor.InvalidActorNameException: actor name [NetworkReceiver-0] is not
unique!
	at
akka.actor.dungeon.ChildrenContainer$NormalChildrenContainer.reserve(ChildrenContainer.scala:130)
	at akka.actor.dungeon.Children$class.reserveChild(Children.scala:77)
	at akka.actor.ActorCell.reserveChild(ActorCell.scala:338)
	at akka.actor.dungeon.Children$class.makeChild(Children.scala:186)
	at akka.actor.dungeon.Children$class.attachChild(Children.scala:42)
	at akka.actor.ActorCell.attachChild(ActorCell.scala:338)
	at akka.actor.ActorSystemImpl.actorOf(ActorSystem.scala:518)
	at
org.apache.spark.streaming.dstream.NetworkReceiver.actor$lzycompute(NetworkInputDStream.scala:94)
	at
org.apache.spark.streaming.dstream.NetworkReceiver.actor(NetworkInputDStream.scala:94)
	at
org.apache.spark.streaming.dstream.NetworkReceiver.start(NetworkInputDStream.scala:122)
	at
org.apache.spark.streaming.scheduler.NetworkInputTracker$ReceiverExecutor$$anonfun$8.apply(NetworkInputTracker.scala:173)
	at
org.apache.spark.streaming.scheduler.NetworkInputTracker$ReceiverExecutor$$anonfun$8.apply(NetworkInputTracker.scala:169)
	at
org.apache.spark.SparkContext$$anonfun$runJob$4.apply(SparkContext.scala:884)
	at
org.apache.spark.SparkContext$$anonfun$runJob$4.apply(SparkContext.scala:884)
	at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:109)
	at org.apache.spark.scheduler.Task.run(Task.scala:53)
	at
org.apache.spark.executor.Executor$TaskRunner$$anonfun$run$1.apply$mcV$sp(Executor.scala:213)
	at
org.apache.spark.deploy.SparkHadoopUtil.runAsUser(SparkHadoopUtil.scala:49)
	at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:178)
	at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:744)

I tried cleaning up the zookeeper and kafka temp/cached files. But still the
same. 

Any help on this ? 




--
View this message in context: http://apache-spark-user-list.1001560.n3.nabble.com/KafkaReciever-Error-when-starting-ssc-Actor-name-not-unique-tp3978.html
Sent from the Apache Spark User List mailing list archive at Nabble.com.