File tree Expand file tree Collapse file tree 1 file changed +7
-2
lines changed
sql/core/src/main/scala/org/apache/spark/sql/sources Expand file tree Collapse file tree 1 file changed +7
-2
lines changed Original file line number Diff line number Diff line change @@ -189,8 +189,13 @@ private[sql] object PartitioningUtils {
189189 Seq .empty
190190 } else {
191191 assert(distinctPartitionsColNames.size == 1 , {
192- val list = distinctPartitionsColNames.mkString(" \t " , " \n\t " , " " )
193- s " Conflicting partition column names detected: \n $list"
192+ val list = distinctPartitionsColNames.map(_.mkString(" , " )).zipWithIndex.map {
193+ case (names, index) =>
194+ s " \t Partition 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."
194199 })
195200
196201 // Resolves possible type conflicts for each column
You can’t perform that action at this time.
0 commit comments