You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iceberg.apache.org by et...@apache.org on 2023/12/22 13:36:06 UTC
(iceberg) branch main updated: Spark: Fix AddFilesProcedure error message when no partitions are found (#9357)
This is an automated email from the ASF dual-hosted git repository.
etudenhoefner pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/iceberg.git
The following commit(s) were added to refs/heads/main by this push:
new a077a2be31 Spark: Fix AddFilesProcedure error message when no partitions are found (#9357)
a077a2be31 is described below
commit a077a2be318b6b21c849ba7754987604c728715b
Author: panbingkun <84...@qq.com>
AuthorDate: Fri Dec 22 21:35:59 2023 +0800
Spark: Fix AddFilesProcedure error message when no partitions are found (#9357)
---
.../java/org/apache/iceberg/spark/procedures/AddFilesProcedure.java | 2 +-
.../java/org/apache/iceberg/spark/procedures/AddFilesProcedure.java | 2 +-
.../java/org/apache/iceberg/spark/procedures/AddFilesProcedure.java | 2 +-
3 files changed, 3 insertions(+), 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
index 7ed239149d..6a05706776 100644
--- 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 @@ class AddFilesProcedure extends BaseProcedure {
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
index 7ed239149d..6a05706776 100644
--- 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 @@ class AddFilesProcedure extends BaseProcedure {
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
index 7ed239149d..6a05706776 100644
--- 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 @@ class AddFilesProcedure extends BaseProcedure {
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);
}
}