From 4554854f1b22c8f999549e7e4c0b0b81ffc9b3fb Mon Sep 17 00:00:00 2001 From: Xin Ren Date: Mon, 14 Mar 2016 14:02:54 -0700 Subject: [PATCH] [SPARK-13660] use method 'testQuietly' to avoid flooding logs --- .../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 dac1a398ff5e..84ed017a9d0d 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 / _)