Skip to content

Commit a6721ca

Browse files
committed
fix ut
1 parent f408912 commit a6721ca

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

sql/hive/src/main/scala/org/apache/spark/sql/hive/client/HiveClientImpl.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -574,7 +574,7 @@ private[hive] class HiveClientImpl(
574574
// If users explicitly alter these Hive-specific properties through ALTER TABLE DDL, we respect
575575
// these user-specified values.
576576
verifyColumnDataType(table.dataSchema)
577-
val owner = if (StringUtils.isEmpty(table.owner)) userName else table.owner
577+
val owner = Option(table.owner).filter(_.nonEmpty).getOrElse(userName)
578578
val hiveTable = toHiveTable(
579579
table.copy(properties = table.ignoredProperties ++ table.properties), Some(owner))
580580
// Do not use `table.qualifiedName` here because this may be a rename

0 commit comments

Comments
 (0)