Update ReceiverTracker.scala

apache · Jun 12, 2015 · bc23907 · bc23907
1 parent 68e8540
commit bc23907
Showing 1 changed file with 2 additions and 2 deletions.
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
@@ -289,15 +289,15 @@ class ReceiverTracker(ssc: StreamingContext, skipReceiverLaunch: Boolean = false
       val locations = new Array[ArrayBuffer[String]](receivers.length)
       if (!executors.isEmpty) {
         var i = 0
-        for (i <- 0 to (receivers.length - 1)) {
+        for (i <- 0 until receivers.length) {
           locations(i) = new ArrayBuffer[String]()
           if (receivers(i).preferredLocation.isDefined) {
             locations(i) += receivers(i).preferredLocation.get
           }
         }
 
         var count = 0;
-        for (i <- 0 to (max(receivers.length, executors.length) - 1)) {
+        for (i <- 0 until max(receivers.length, executors.length)) {
           if (!receivers(i % receivers.length).preferredLocation.isDefined) {
             locations(i % receivers.length) += executors(count)
             count += 1;