From 1a55a95e8c8965cfc1cda0496d6f1c63145d0ae7 Mon Sep 17 00:00:00 2001 From: CodingCat Date: Mon, 5 May 2014 22:35:41 -0400 Subject: [PATCH] use auto-generated name in JobScheduler Actor --- .../org/apache/spark/streaming/scheduler/JobScheduler.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/streaming/src/main/scala/org/apache/spark/streaming/scheduler/JobScheduler.scala b/streaming/src/main/scala/org/apache/spark/streaming/scheduler/JobScheduler.scala index 1b034b9fb187c..47c57e68b398c 100644 --- a/streaming/src/main/scala/org/apache/spark/streaming/scheduler/JobScheduler.scala +++ b/streaming/src/main/scala/org/apache/spark/streaming/scheduler/JobScheduler.scala @@ -58,7 +58,7 @@ class JobScheduler(val ssc: StreamingContext) extends Logging { def receive = { case event: JobSchedulerEvent => processEvent(event) } - }), "JobScheduler") + })) listenerBus.start() receiverTracker = new ReceiverTracker(ssc)