File tree Expand file tree Collapse file tree 1 file changed +4
-2
lines changed
sql/core/src/main/scala/org/apache/spark/sql/execution/command Expand file tree Collapse file tree 1 file changed +4
-2
lines changed Original file line number Diff line number Diff line change @@ -539,10 +539,12 @@ case class AlterTableDropPartitionCommand(
539539 if (partition._2 != null ) {
540540 partition._2.references.foreach { attr =>
541541 if (! table.partitionColumnNames.exists(resolver(_, attr.name))) {
542- throw new AnalysisException (s " ${attr.name} is not a valid partition column " + s " in table ${table.identifier.quotedString}. " )
542+ throw new AnalysisException (s " ${attr.name} is not a valid partition column " +
543+ s " in table ${table.identifier.quotedString}. " )
543544 }
544545 }
545- val partitions = catalog.listPartitionsByFilter(table.identifier, Seq (partition._2)).map(_.spec)
546+ val partitions = catalog.listPartitionsByFilter(
547+ table.identifier, Seq (partition._2)).map(_.spec)
546548 if (partitions.isEmpty && ! ifExists) {
547549 throw new AnalysisException (s " There is no partition for ${partition._2.sql}" )
548550 }
You can’t perform that action at this time.
0 commit comments