We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent d96d7b5 commit a935eb8Copy full SHA for a935eb8
1 file changed
sql/core/src/main/scala/org/apache/spark/sql/sources/PartitioningUtils.scala
@@ -189,8 +189,13 @@ private[sql] object PartitioningUtils {
189
Seq.empty
190
} else {
191
assert(distinctPartitionsColNames.size == 1, {
192
- val list = distinctPartitionsColNames.mkString("\t", "\n\t", "")
193
- s"Conflicting partition column names detected:\n$list"
+ val list = distinctPartitionsColNames.map(_.mkString(", ")).zipWithIndex.map {
+ case (names, index) =>
194
+ s"\tPartition column name list #$index: $names"
195
+ }
196
+
197
+ s"Conflicting partition column names detected:\n${list.mkString("\n")}\n" +
198
+ "For partitioned table directories, data files should only live in leaf directories."
199
})
200
201
// Resolves possible type conflicts for each column
0 commit comments