diff options
author | Sandeep <sandeep@techaddict.me> | 2014-04-24 15:07:23 -0700 |
---|---|---|
committer | Reynold Xin <rxin@apache.org> | 2014-04-24 15:07:32 -0700 |
commit | 2250c7acbd857efeda99d9e850cb0faff34e19f0 (patch) | |
tree | bcb1442137349f82ac4c7b83c88b67de98cf21cb /streaming/src/main | |
parent | 5ca01f68197ab3274a7115220949f671dab6dc0f (diff) | |
download | spark-2250c7acbd857efeda99d9e850cb0faff34e19f0.tar.gz spark-2250c7acbd857efeda99d9e850cb0faff34e19f0.tar.bz2 spark-2250c7acbd857efeda99d9e850cb0faff34e19f0.zip |
Fix Scala Style
Any comments are welcome
Author: Sandeep <sandeep@techaddict.me>
Closes #531 from techaddict/stylefix-1 and squashes the following commits:
7492730 [Sandeep] Pass 4
98b2428 [Sandeep] fix rxin suggestions
b5e2e6f [Sandeep] Pass 3
05932d7 [Sandeep] fix if else styling 2
08690e5 [Sandeep] fix if else styling
(cherry picked from commit a03ac222d84025a1036750e1179136a13f75dea7)
Signed-off-by: Reynold Xin <rxin@apache.org>
Diffstat (limited to 'streaming/src/main')
-rw-r--r-- | streaming/src/main/scala/org/apache/spark/streaming/scheduler/ReceiverTracker.scala | 3 |
1 files changed, 1 insertions, 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 index 3d2537f6f2..557e0961d5 100644 --- a/streaming/src/main/scala/org/apache/spark/streaming/scheduler/ReceiverTracker.scala +++ b/streaming/src/main/scala/org/apache/spark/streaming/scheduler/ReceiverTracker.scala @@ -240,8 +240,7 @@ class ReceiverTracker(ssc: StreamingContext) extends Logging { if (hasLocationPreferences) { val receiversWithPreferences = receivers.map(r => (r, Seq(r.preferredLocation.get))) ssc.sc.makeRDD[Receiver[_]](receiversWithPreferences) - } - else { + } else { ssc.sc.makeRDD(receivers, receivers.size) } |