Skip to content

Commit bcdae88

Browse files
committed
Fix
1 parent b298522 commit bcdae88

1 file changed

Lines changed: 3 additions & 2 deletions

File tree

‎sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveExternalCatalog.scala‎

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -150,9 +150,10 @@ private[spark] class HiveExternalCatalog(conf: SparkConf, hadoopConf: Configurat
150150
f.dataType match {
151151
case st: StructType => verifyNestedColumnNames(st)
152152
case _ if invalidChars.exists(f.name.contains) =>
153+
val invalidCharsString = invalidChars.map(c => s"'$c'").mkString(", ")
153154
val errMsg = "Cannot create a table having a nested column whose name contains " +
154-
s"invalid characters (${invalidChars.map(c => s"'$c'").mkString(", ")}) " +
155-
s"in Hive metastore. Table: $tableName; Column: ${f.name}"
155+
s"invalid characters ($invalidCharsString) in Hive metastore. Table: $tableName; " +
156+
s"Column: ${f.name}"
156157
throw new AnalysisException(errMsg)
157158
case _ =>
158159
}

0 commit comments

Comments
 (0)