From 8be6934030ac2a0ce6b05de1670a5e5c0e771c8a Mon Sep 17 00:00:00 2001 From: David McGuire Date: Mon, 20 Apr 2015 09:36:38 -0700 Subject: [PATCH] Fix spacing per code review --- .../scala/org/apache/spark/streaming/receiver/RateLimiter.scala | 2 +- 1 file changed, 1 insertion(+), 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 index 9be69ba572700..97db9ded83367 100644 --- 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() } }