Update ReceiverTracker.scala

apache · Jun 5, 2015 · 16e84ec · 16e84ec
1 parent 45e3a99
commit 16e84ec
Showing 1 changed file with 2 additions 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
@@ -317,7 +317,8 @@ class ReceiverTracker(ssc: StreamingContext, skipReceiverLaunch: Boolean = false
           val receiversWithPreferences = receivers.map(r => (r, Seq(r.preferredLocation.get)))
           ssc.sc.makeRDD[Receiver[_]](receiversWithPreferences)
         } else if (roundRobin) {
-          val roundRobinReceivers = (0 to (receivers.length - 1)).map(i => (receivers(i), locations(i)))
+          val roundRobinReceivers = (0 to (receivers.length - 1)).map(i => 
+	    (receivers(i), locations(i)))
           ssc.sc.makeRDD[Receiver[_]](roundRobinReceivers)
         } else {
           ssc.sc.makeRDD(receivers, receivers.size)