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 6fd5e29f3e Spark: Log failed catalog load in
Spark3Util::catalogAndIdentifier (#14183)
6fd5e29f3e is described below
commit 6fd5e29f3ef4b0fe62ab2805861bfcf3973f79c8
Author: Hugo Wong-Berard <[email protected]>
AuthorDate: Thu Oct 2 07:02:58 2025 +0100
Spark: Log failed catalog load in Spark3Util::catalogAndIdentifier (#14183)
---
.../spark/src/main/java/org/apache/iceberg/spark/Spark3Util.java | 5 +++++
1 file changed, 5 insertions(+)
diff --git
a/spark/v4.0/spark/src/main/java/org/apache/iceberg/spark/Spark3Util.java
b/spark/v4.0/spark/src/main/java/org/apache/iceberg/spark/Spark3Util.java
index 2fd75e6a57..df42175c34 100644
--- a/spark/v4.0/spark/src/main/java/org/apache/iceberg/spark/Spark3Util.java
+++ b/spark/v4.0/spark/src/main/java/org/apache/iceberg/spark/Spark3Util.java
@@ -92,12 +92,16 @@ import org.apache.spark.sql.types.IntegerType;
import org.apache.spark.sql.types.LongType;
import org.apache.spark.sql.types.StructType;
import org.apache.spark.sql.util.CaseInsensitiveStringMap;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
import scala.Option;
import scala.collection.JavaConverters;
import scala.collection.immutable.Seq;
public class Spark3Util {
+ private static final Logger LOG = LoggerFactory.getLogger(Spark3Util.class);
+
private static final Set<String> RESERVED_PROPERTIES =
ImmutableSet.of(TableCatalog.PROP_LOCATION, TableCatalog.PROP_PROVIDER);
private static final Joiner DOT = Joiner.on(".");
@@ -810,6 +814,7 @@ public class Spark3Util {
try {
return catalogManager.catalog(catalogName);
} catch (Exception e) {
+ LOG.warn("Failed to load catalog: {}", catalogName, e);
return null;
}
},
