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:23 -0700 |
| commit | a03ac222d84025a1036750e1179136a13f75dea7 (patch) | |
| tree | cc7f041b35b7804b7d62520f279cc6e53e40d73c /streaming | |
| parent | c5c1916dd1b77e22759d58b5b361c56672983e3e (diff) | |
| download | spark-a03ac222d84025a1036750e1179136a13f75dea7.tar.gz spark-a03ac222d84025a1036750e1179136a13f75dea7.tar.bz2 spark-a03ac222d84025a1036750e1179136a13f75dea7.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
Diffstat (limited to 'streaming')
| -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) } |