Fix spacing per code review

markhamstra · Apr 20, 2015 · 8be6934 · 8be6934
1 parent 90e98b9
commit 8be6934
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/streaming/src/main/scala/org/apache/spark/streaming/receiver/RateLimiter.scala b/streaming/src/main/scala/org/apache/spark/streaming/receiver/RateLimiter.scala
@@ -37,7 +37,7 @@ private[receiver] abstract class RateLimiter(conf: SparkConf) extends Logging {
   private lazy val rateLimiter = GuavaRateLimiter.create(desiredRate)
 
   def waitToPush() {
-    if( desiredRate > 0 ) {
+    if (desiredRate > 0) {
       rateLimiter.acquire()
     }
   }