Spark: Fix AddFilesProcedure error message when no partitions are fou…

…nd (apache#9357)
lisirrx · Jan 4, 2024 · 723e4f1 · 723e4f1
1 parent 5e65383
commit 723e4f1
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/spark/v3.3/spark/src/main/java/org/apache/iceberg/spark/procedures/AddFilesProcedure.java b/spark/v3.3/spark/src/main/java/org/apache/iceberg/spark/procedures/AddFilesProcedure.java
@@ -196,7 +196,7 @@ private void importFileTable(
       importPartitions(table, ImmutableList.of(partition), checkDuplicateFiles);
     } else {
       Preconditions.checkArgument(
-          !partitions.isEmpty(), "Cannot find any matching partitions in table %s", partitions);
+          !partitions.isEmpty(), "Cannot find any matching partitions in table %s", table.name());
       importPartitions(table, partitions, checkDuplicateFiles);
     }
   }

diff --git a/spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/procedures/AddFilesProcedure.java b/spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/procedures/AddFilesProcedure.java
@@ -196,7 +196,7 @@ private void importFileTable(
       importPartitions(table, ImmutableList.of(partition), checkDuplicateFiles);
     } else {
       Preconditions.checkArgument(
-          !partitions.isEmpty(), "Cannot find any matching partitions in table %s", partitions);
+          !partitions.isEmpty(), "Cannot find any matching partitions in table %s", table.name());
       importPartitions(table, partitions, checkDuplicateFiles);
     }
   }

diff --git a/spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/procedures/AddFilesProcedure.java b/spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/procedures/AddFilesProcedure.java
@@ -196,7 +196,7 @@ private void importFileTable(
       importPartitions(table, ImmutableList.of(partition), checkDuplicateFiles);
     } else {
       Preconditions.checkArgument(
-          !partitions.isEmpty(), "Cannot find any matching partitions in table %s", partitions);
+          !partitions.isEmpty(), "Cannot find any matching partitions in table %s", table.name());
       importPartitions(table, partitions, checkDuplicateFiles);
     }
   }