diff --git a/sql/core/src/test/scala/org/apache/spark/sql/test/SQLTestUtils.scala b/sql/core/src/test/scala/org/apache/spark/sql/test/SQLTestUtils.scala index e68db3b636bced0025e0c6eaf8444c5b63af2f10..a14a1441a4313b69f80f36bc24931cc07d661775 100644 --- a/sql/core/src/test/scala/org/apache/spark/sql/test/SQLTestUtils.scala +++ b/sql/core/src/test/scala/org/apache/spark/sql/test/SQLTestUtils.scala @@ -247,7 +247,7 @@ private[sql] trait SQLTestUtils protected def withDatabase(dbNames: String*)(f: => Unit): Unit = { try f finally { dbNames.foreach { name => - spark.sql(s"DROP DATABASE IF EXISTS $name") + spark.sql(s"DROP DATABASE IF EXISTS $name CASCADE") } spark.sql(s"USE $DEFAULT_DATABASE") }