Update ReceiverTracker.scala

maropu · Jun 5, 2015 · f8a3e05 · f8a3e05
1 parent 4cf97b6
commit f8a3e05
Showing 1 changed file with 1 addition and 0 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,6 +289,7 @@ class ReceiverTracker(ssc: StreamingContext, skipReceiverLaunch: Boolean = false
 
       // If no location preferences are specified, set host location for each receiver
       // so as to distribute them evenly over executors in a round-robin fashion
+      // If num_receivers > num_executors, distribute receivers among executors
       // If num_executors > num_receivers, distribute executors among receivers
       val locations = new Array[ArrayBuffer[String]](receivers.length)
       var roundRobin = false