Update ReceiverTracker.scala

apache · Jun 12, 2015 · 48a4a97 · 48a4a97
1 parent bc23907
commit 48a4a97
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
@@ -348,7 +348,7 @@ class ReceiverTracker(ssc: StreamingContext, skipReceiverLaunch: Boolean = false
       val locations = scheduleReceivers(receivers, executors)
       val tempRDD =
         if (locations(0) != null) {
-          val roundRobinReceivers = (0 to (receivers.length - 1)).map(i =>
+          val roundRobinReceivers = (0 until receivers.length).map(i =>
             (receivers(i), locations(i)))
           ssc.sc.makeRDD[Receiver[_]](roundRobinReceivers)
         } else {