We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 3c96091 commit 7188587Copy full SHA for 7188587
sql/core/src/main/scala/org/apache/spark/sql/execution/command/ddl.scala
@@ -72,13 +72,12 @@ case class CreateDatabaseCommand(
72
73
override def run(sparkSession: SparkSession): Seq[Row] = {
74
val catalog = sparkSession.sessionState.catalog
75
- val availablePros = props -- RESERVED_PROPERTIES.asScala
76
catalog.createDatabase(
77
CatalogDatabase(
78
databaseName,
79
comment.getOrElse(""),
80
path.map(CatalogUtils.stringToURI).getOrElse(catalog.getDefaultDBPath(databaseName)),
81
- availablePros),
+ props),
82
ifNotExists)
83
Seq.empty[Row]
84
}
0 commit comments