Skip to content

Commit 7739ccd

Browse files
committed
mv getdatabase
1 parent ae9938a commit 7739ccd

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/catalog/ExternalCatalog.scala

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -89,14 +89,13 @@ abstract class ExternalCatalog(conf: SparkConf, hadoopConf: Configuration) {
8989
def alterDatabase(dbDefinition: CatalogDatabase): Unit
9090

9191
final def getDatabase(db: String): CatalogDatabase = {
92-
val database = getDatabaseInternal(db)
9392
// The default database's location always uses the warehouse path.
9493
// Since the location of database stored in metastore is qualified,
9594
// we also make the warehouse location qualified.
9695
if (db == SessionCatalog.DEFAULT_DATABASE) {
9796
defaultDB
9897
} else {
99-
database
98+
getDatabaseInternal(db)
10099
}
101100
}
102101

0 commit comments

Comments
 (0)