Skip to content

Commit b190b86

Browse files
committed
address comments
1 parent 55cf518 commit b190b86

File tree

1 file changed

+2
-5
lines changed
  • sql/core/src/test/scala/org/apache/spark/sql/execution/command

1 file changed

+2
-5
lines changed

sql/core/src/test/scala/org/apache/spark/sql/execution/command/DDLSuite.scala

Lines changed: 2 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -95,10 +95,6 @@ class DDLSuite extends QueryTest with SharedSQLContext with BeforeAndAfterEach {
9595
catalog.createPartitions(tableName, Seq(part), ignoreIfExists = false)
9696
}
9797

98-
private def dropTable(catalog: SessionCatalog, name: TableIdentifier): Unit = {
99-
catalog.dropTable(name, ignoreIfNotExists = false)
100-
}
101-
10298
private def appendTrailingSlash(path: String): String = {
10399
if (!path.endsWith(File.separator)) path + File.separator else path
104100
}
@@ -303,7 +299,8 @@ class DDLSuite extends QueryTest with SharedSQLContext with BeforeAndAfterEach {
303299
}.getMessage
304300
assert(message.contains(s"Database '$dbName' is not empty. One or more tables exist"))
305301

306-
dropTable(catalog, tableIdent1)
302+
catalog.dropTable(tableIdent1, ignoreIfNotExists = false)
303+
307304
assert(catalog.listDatabases().contains(dbName))
308305
sql(s"DROP DATABASE $dbName RESTRICT")
309306
assert(!catalog.listDatabases().contains(dbName))

0 commit comments

Comments
 (0)