This is an automated email from the ASF dual-hosted git repository.
junhao pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git
The following commit(s) were added to refs/heads/master by this push:
new 35e2d25bad [hotfix] Fix compile error in PaimonDescribeTableExec
(#6398)
35e2d25bad is described below
commit 35e2d25bad69c430de8de6120b2c737bc8c8405c
Author: Zouxxyy <[email protected]>
AuthorDate: Tue Oct 14 15:44:02 2025 +0800
[hotfix] Fix compile error in PaimonDescribeTableExec (#6398)
---
.../org/apache/spark/sql/execution/PaimonDescribeTableExec.scala | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/paimon-spark/paimon-spark-common/src/main/scala/org/apache/spark/sql/execution/PaimonDescribeTableExec.scala
b/paimon-spark/paimon-spark-common/src/main/scala/org/apache/spark/sql/execution/PaimonDescribeTableExec.scala
index add6f4cc1b..50af431fd1 100644
---
a/paimon-spark/paimon-spark-common/src/main/scala/org/apache/spark/sql/execution/PaimonDescribeTableExec.scala
+++
b/paimon-spark/paimon-spark-common/src/main/scala/org/apache/spark/sql/execution/PaimonDescribeTableExec.scala
@@ -74,14 +74,14 @@ case class PaimonDescribeTableExec(
}
private def describeFormattedDetailedPartitionInfo(rows:
ArrayBuffer[InternalRow]): Unit = {
- checkNamespace(identifier.namespace())
+ checkNamespace(identifier.namespace(), catalog.name())
rows += emptyRow()
rows += toCatalystRow("# Detailed Partition Information", "", "")
rows += toCatalystRow("Database", identifier.namespace().head, "")
rows += toCatalystRow("Table", identifier.name(), "")
val partition = catalog
.paimonCatalog()
- .listPartitions(toIdentifier(identifier))
+ .listPartitions(toIdentifier(identifier, catalog.name()))
.asScala
.filter(_.spec().asScala == partitionSpec)
if (partition.size != 1) {