aboutsummaryrefslogtreecommitdiff
path: root/sql/core/src
diff options
context:
space:
mode:
authorXin Ren <iamshrek@126.com>2016-03-15 01:02:28 -0700
committerReynold Xin <rxin@databricks.com>2016-03-15 01:02:28 -0700
commit10251a7457e44fa33f13274ccb2266bc5e931363 (patch)
tree45c544793d79dfed4b98a0c0430c782bc9c509ed /sql/core/src
parent99bd2f0e94657687834c5c59c4270c1484c9f595 (diff)
downloadspark-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/core/src')
-rw-r--r--sql/core/src/test/scala/org/apache/spark/sql/streaming/ContinuousQuerySuite.scala4
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 / _)