diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/AlreadyExistException.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/AlreadyExistException.scala index 04699dc56967..f65c29a06cc6 100644 --- a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/AlreadyExistException.scala +++ b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/AlreadyExistException.scala @@ -79,7 +79,7 @@ class PartitionsAlreadyExistException(message: String) extends AnalysisException def this(tableName: String, partitionIdents: Seq[InternalRow], partitionSchema: StructType) = { this(s"The following partitions already exists in table $tableName:" + - partitionIdents.map(_.toSeq(partitionSchema).zip(partitionSchema.map(_.name)) + partitionIdents.map(id => partitionSchema.map(_.name).zip(id.toSeq(partitionSchema)) .map( kv => s"${kv._1} -> ${kv._2}").mkString(",")).mkString("\n===\n")) } } diff --git a/sql/core/src/test/scala/org/apache/spark/sql/execution/command/v2/AlterTableAddPartitionSuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/execution/command/v2/AlterTableAddPartitionSuite.scala index 2784f1e4bddc..a238dfcf2dd9 100644 --- a/sql/core/src/test/scala/org/apache/spark/sql/execution/command/v2/AlterTableAddPartitionSuite.scala +++ b/sql/core/src/test/scala/org/apache/spark/sql/execution/command/v2/AlterTableAddPartitionSuite.scala @@ -111,7 +111,7 @@ class AlterTableAddPartitionSuite sql(s"ALTER TABLE $t ADD PARTITION (id=1) LOCATION 'loc'" + " PARTITION (id=2) LOCATION 'loc1'") }.getMessage - assert(errMsg === s"The following partitions already exists in table $t:2 -> id") + assert(errMsg === s"The following partitions already exists in table $t:id -> 2") sql(s"ALTER TABLE $t ADD IF NOT EXISTS PARTITION (id=1) LOCATION 'loc'" + " PARTITION (id=2) LOCATION 'loc1'")