Update ReceiverTracker.scala

apache · Jun 5, 2015 · b05ee2f · b05ee2f
1 parent bb5e09b
commit b05ee2f
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
@@ -333,7 +333,7 @@ class ReceiverTracker(ssc: StreamingContext, skipReceiverLaunch: Boolean = false
         if (hasLocationPreferences) {
           val receiversWithPreferences = receivers.map(r => (r, Seq(r.preferredLocation.get)))
           ssc.sc.makeRDD[Receiver[_]](receiversWithPreferences)
-        } else if(roundRobin) {
+        } else if (roundRobin) {
           val roundRobinReceivers = receivers.map(r => (r, Seq(r.host.get)))
           ssc.sc.makeRDD[Receiver[_]](roundRobinReceivers)
         } else {