(paimon) branch master updated: [spark] Improve unsupported provider error message with catalog details (#8004)

[lzljs3620320]

This is an automated email from the ASF dual-hosted git repository.

JingsongLi 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 90ceba5d39 [spark] Improve unsupported provider error message with 
catalog details (#8004)
90ceba5d39 is described below

commit 90ceba5d398659da6f3dc9867e097b25334d5432
Author: Zouxxyy <zouxinyu....@alibaba-inc.com>
AuthorDate: Thu May 28 15:25:55 2026 +0800

    [spark] Improve unsupported provider error message with catalog details 
(#8004)
---
 .../src/main/java/org/apache/paimon/spark/SparkCatalog.java       | 8 +++++++-
 .../src/test/scala/org/apache/paimon/spark/sql/DDLTestBase.scala  | 2 +-
 2 files changed, 8 insertions(+), 2 deletions(-)

diff --git 
a/paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkCatalog.java
 
b/paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkCatalog.java
index 913d4f582a..c6d35f6d81 100644
--- 
a/paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkCatalog.java
+++ 
b/paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/SparkCatalog.java
@@ -569,7 +569,13 @@ public class SparkCatalog extends SparkBaseCatalog
                 normalizedProperties.put(TYPE.key(), FORMAT_TABLE.toString());
                 normalizedProperties.put(FILE_FORMAT.key(), 
provider.toLowerCase());
             } else {
-                throw new UnsupportedOperationException("Provider is not 
supported: " + provider);
+                throw new UnsupportedOperationException(
+                        String.format(
+                                "Provider '%s' is not supported by catalog 
'%s' (implementation: %s). Supported providers: [paimon, %s]",
+                                provider,
+                                catalogName,
+                                getClass().getSimpleName(),
+                                SparkSource.FORMAT_NAMES().mkString(", ")));
             }
         }
         normalizedProperties.remove(TableCatalog.PROP_PROVIDER);
diff --git 
a/paimon-spark/paimon-spark-ut/src/test/scala/org/apache/paimon/spark/sql/DDLTestBase.scala
 
b/paimon-spark/paimon-spark-ut/src/test/scala/org/apache/paimon/spark/sql/DDLTestBase.scala
index b44561a09c..98cac73f4a 100644
--- 
a/paimon-spark/paimon-spark-ut/src/test/scala/org/apache/paimon/spark/sql/DDLTestBase.scala
+++ 
b/paimon-spark/paimon-spark-ut/src/test/scala/org/apache/paimon/spark/sql/DDLTestBase.scala
@@ -860,7 +860,7 @@ abstract class DDLTestBase extends PaimonSparkTestBase {
   test("Paimon DDL: create unsupported table") {
     assert(intercept[Exception] {
       sql("CREATE TABLE t (id INT) USING paimon1")
-    }.getMessage.contains("Provider is not supported: paimon1"))
+    }.getMessage.contains("Provider 'paimon1' is not supported"))
   }
 
   test("Paimon DDL: Drop Partition by partial spec") {