Skip to content
Snippets Groups Projects
Commit 05dc3856 authored by Prashant Sharma's avatar Prashant Sharma
Browse files

A bug fix post merge, following changes to AkkaUtils

parent 8b9c673f
No related branches found
No related tags found
No related merge requests found
......@@ -147,7 +147,7 @@ object ActorWordCount {
*/
val lines = ssc.actorStream[String](
Props(new SampleActorReceiver[String]("akka://spark@%s:%s/user/FeederActor".format(
Props(new SampleActorReceiver[String]("akka://test@%s:%s/user/FeederActor".format(
host, port.toInt))), "SampleReceiver")
//compute wordcount
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment