From 41705de8ff77ddf616f9fa85168c050b64442467 Mon Sep 17 00:00:00 2001 From: nishkamravi2 Date: Wed, 3 Jun 2015 00:48:53 -0700 Subject: [PATCH] Update ReceiverTracker.scala --- .../org/apache/spark/streaming/scheduler/ReceiverTracker.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/streaming/src/main/scala/org/apache/spark/streaming/scheduler/ReceiverTracker.scala b/streaming/src/main/scala/org/apache/spark/streaming/scheduler/ReceiverTracker.scala index e548def402409..b9fb17d981836 100644 --- a/streaming/src/main/scala/org/apache/spark/streaming/scheduler/ReceiverTracker.scala +++ b/streaming/src/main/scala/org/apache/spark/streaming/scheduler/ReceiverTracker.scala @@ -324,7 +324,7 @@ class ReceiverTracker(ssc: StreamingContext, skipReceiverLaunch: Boolean = false for (i <- 0 to (receivers.length - 1)) { receivers(i).preferredLocation = Some(executors(i % executors.length)) } - hasLocationPreferences = true; + hasLocationPreferences = true } }