Update ReceiverTracker.scala

apache · Jun 3, 2015 · 41705de · 41705de
1 parent fff1b2e
commit 41705de
Showing 1 changed file with 1 addition and 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
@@ -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
         }
       }