diff options
author | Reynold Xin <rxin@databricks.com> | 2015-04-08 00:24:59 -0700 |
---|---|---|
committer | Reynold Xin <rxin@databricks.com> | 2015-04-08 00:24:59 -0700 |
commit | 15e0d2bd1304db62fad286c1bb687e87c361e16c (patch) | |
tree | bcdc2f0018de4cbd492c815428fadb671fb74bcf /external/mqtt/src | |
parent | 8d2a36c0fdfbea9f58271ef6aeb89bb79b22cf62 (diff) | |
download | spark-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.scala | 3 |
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) } } } |