From 10251a7457e44fa33f13274ccb2266bc5e931363 Mon Sep 17 00:00:00 2001
From: Xin Ren <iamshrek@126.com>
Date: Tue, 15 Mar 2016 01:02:28 -0700
Subject: [PATCH] [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.
---
.../org/apache/spark/sql/streaming/ContinuousQuerySuite.scala | 4 ++--
1 file 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 / _)
--
GitLab