aboutsummaryrefslogtreecommitdiff
path: root/external/mqtt/src
diff options
context:
space:
mode:
authorReynold Xin <rxin@databricks.com>2015-04-08 00:24:59 -0700
committerReynold Xin <rxin@databricks.com>2015-04-08 00:24:59 -0700
commit15e0d2bd1304db62fad286c1bb687e87c361e16c (patch)
treebcdc2f0018de4cbd492c815428fadb671fb74bcf /external/mqtt/src
parent8d2a36c0fdfbea9f58271ef6aeb89bb79b22cf62 (diff)
downloadspark-15e0d2bd1304db62fad286c1bb687e87c361e16c.tar.gz
spark-15e0d2bd1304db62fad286c1bb687e87c361e16c.tar.bz2
spark-15e0d2bd1304db62fad286c1bb687e87c361e16c.zip
[SPARK-6765] Fix test code style for streaming.
So we can turn style checker on for test code. Author: Reynold Xin <rxin@databricks.com> Closes #5409 from rxin/test-style-streaming and squashes the following commits: 7aea69b [Reynold Xin] [SPARK-6765] Fix test code style for streaming.
Diffstat (limited to 'external/mqtt/src')
-rw-r--r--external/mqtt/src/test/scala/org/apache/spark/streaming/mqtt/MQTTStreamSuite.scala3
1 files changed, 2 insertions, 1 deletions
diff --git a/external/mqtt/src/test/scala/org/apache/spark/streaming/mqtt/MQTTStreamSuite.scala b/external/mqtt/src/test/scala/org/apache/spark/streaming/mqtt/MQTTStreamSuite.scala
index 24d78ecb3a..a19a72c58a 100644
--- a/external/mqtt/src/test/scala/org/apache/spark/streaming/mqtt/MQTTStreamSuite.scala
+++ b/external/mqtt/src/test/scala/org/apache/spark/streaming/mqtt/MQTTStreamSuite.scala
@@ -139,7 +139,8 @@ class MQTTStreamSuite extends FunSuite with Eventually with BeforeAndAfter {
msgTopic.publish(message)
} catch {
case e: MqttException if e.getReasonCode == MqttException.REASON_CODE_MAX_INFLIGHT =>
- Thread.sleep(50) // wait for Spark streaming to consume something from the message queue
+ // wait for Spark streaming to consume something from the message queue
+ Thread.sleep(50)
}
}
}