Skip to content

Commit 35e2d25

Browse files
authored
[hotfix] Fix compile error in PaimonDescribeTableExec (#6398)
1 parent 8b542c5 commit 35e2d25

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

paimon-spark/paimon-spark-common/src/main/scala/org/apache/spark/sql/execution/PaimonDescribeTableExec.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -74,14 +74,14 @@ case class PaimonDescribeTableExec(
7474
}
7575

7676
private def describeFormattedDetailedPartitionInfo(rows: ArrayBuffer[InternalRow]): Unit = {
77-
checkNamespace(identifier.namespace())
77+
checkNamespace(identifier.namespace(), catalog.name())
7878
rows += emptyRow()
7979
rows += toCatalystRow("# Detailed Partition Information", "", "")
8080
rows += toCatalystRow("Database", identifier.namespace().head, "")
8181
rows += toCatalystRow("Table", identifier.name(), "")
8282
val partition = catalog
8383
.paimonCatalog()
84-
.listPartitions(toIdentifier(identifier))
84+
.listPartitions(toIdentifier(identifier, catalog.name()))
8585
.asScala
8686
.filter(_.spec().asScala == partitionSpec)
8787
if (partition.size != 1) {

0 commit comments

Comments
 (0)