diff options
| -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 / _) |