diff options
author | Xin Ren <iamshrek@126.com> | 2016-03-15 01:02:28 -0700 |
---|---|---|
committer | Reynold Xin <rxin@databricks.com> | 2016-03-15 01:02:28 -0700 |
commit | 10251a7457e44fa33f13274ccb2266bc5e931363 (patch) | |
tree | 45c544793d79dfed4b98a0c0430c782bc9c509ed /sql | |
parent | 99bd2f0e94657687834c5c59c4270c1484c9f595 (diff) | |
download | spark-10251a7457e44fa33f13274ccb2266bc5e931363.tar.gz spark-10251a7457e44fa33f13274ccb2266bc5e931363.tar.bz2 spark-10251a7457e44fa33f13274ccb2266bc5e931363.zip |
[SPARK-13660][SQL][TESTS] ContinuousQuerySuite floods the logs with garbage
## What changes were proposed in this pull request?
Use method 'testQuietly' to avoid ContinuousQuerySuite flooding the console logs with garbage
Make ContinuousQuerySuite not output logs to the console. The logs will still output to unit-tests.log.
## How was this patch tested?
Just check Jenkins output.
Author: Xin Ren <iamshrek@126.com>
Closes #11703 from keypointt/SPARK-13660.
Diffstat (limited to 'sql')
-rw-r--r-- | sql/core/src/test/scala/org/apache/spark/sql/streaming/ContinuousQuerySuite.scala | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/sql/core/src/test/scala/org/apache/spark/sql/streaming/ContinuousQuerySuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/streaming/ContinuousQuerySuite.scala index dac1a398ff..84ed017a9d 100644 --- a/sql/core/src/test/scala/org/apache/spark/sql/streaming/ContinuousQuerySuite.scala +++ b/sql/core/src/test/scala/org/apache/spark/sql/streaming/ContinuousQuerySuite.scala @@ -27,7 +27,7 @@ class ContinuousQuerySuite extends StreamTest with SharedSQLContext { import AwaitTerminationTester._ import testImplicits._ - test("lifecycle states and awaitTermination") { + testQuietly("lifecycle states and awaitTermination") { val inputData = MemoryStream[Int] val mapped = inputData.toDS().map { 6 / _} @@ -59,7 +59,7 @@ class ContinuousQuerySuite extends StreamTest with SharedSQLContext { ) } - test("source and sink statuses") { + testQuietly("source and sink statuses") { val inputData = MemoryStream[Int] val mapped = inputData.toDS().map(6 / _) |