(paimon) branch master updated: [spark] Fix wrong argument in procedure (#7067)

[lzljs3620320]

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

lzljs3620320 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 19233c26c5 [spark] Fix wrong argument in procedure (#7067)
19233c26c5 is described below

commit 19233c26c5517e31075f86b3534819b35f4cf18f
Author: huangxiaoping <1754789...@qq.com>
AuthorDate: Sat Jan 17 09:37:09 2026 +0800

    [spark] Fix wrong argument in procedure (#7067)
---
 .../org/apache/paimon/spark/procedure/RemoveOrphanFilesProcedure.java | 2 +-
 .../apache/paimon/spark/procedure/RemoveUnexistingFilesProcedure.java | 4 ++--
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/procedure/RemoveOrphanFilesProcedure.java
 
b/paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/procedure/RemoveOrphanFilesProcedure.java
index 7ddf2eba03..913b30fd0b 100644
--- 
a/paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/procedure/RemoveOrphanFilesProcedure.java
+++ 
b/paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/procedure/RemoveOrphanFilesProcedure.java
@@ -96,7 +96,7 @@ public class RemoveOrphanFilesProcedure extends BaseProcedure 
{
         Preconditions.checkArgument(
                 tableId != null && !tableId.isEmpty(),
                 "Cannot handle an empty tableId for argument %s",
-                tableId);
+                PARAMETERS[0].name());
 
         if (tableId.endsWith(".*")) {
             identifier = 
org.apache.paimon.catalog.Identifier.fromString(tableId);
diff --git 
a/paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/procedure/RemoveUnexistingFilesProcedure.java
 
b/paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/procedure/RemoveUnexistingFilesProcedure.java
index 555fcb1457..171f84f961 100644
--- 
a/paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/procedure/RemoveUnexistingFilesProcedure.java
+++ 
b/paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/procedure/RemoveUnexistingFilesProcedure.java
@@ -42,7 +42,7 @@ import java.util.Arrays;
  *  CALL sys.remove_unexisting_files(`table` => 'mydb.myt')
  *
  *  -- only check what files will be removed, but not really remove them (dry 
run)
- *  CALL sys.remove_unexisting_files(`table` => 'mydb.myt', `dry_run` = true)
+ *  CALL sys.remove_unexisting_files(`table` => 'mydb.myt', `dry_run` => true)
  * </code></pre>
  *
  * <p>Note that user is on his own risk using this procedure, which may cause 
data loss when used
@@ -85,7 +85,7 @@ public class RemoveUnexistingFilesProcedure extends 
BaseProcedure {
         Preconditions.checkArgument(
                 tableId != null && !tableId.isEmpty(),
                 "Cannot handle an empty tableId for argument %s",
-                tableId);
+                PARAMETERS[0].name());
         org.apache.paimon.catalog.Identifier identifier =
                 org.apache.paimon.catalog.Identifier.fromString(
                         toIdentifier(args.getString(0), 
PARAMETERS[0].name()).toString());