[ARCTIC-1280][Spark]Fix bug: When the AMS deployment of high availabi…

…lity, use ArcticSparkSessionCatalog loadTable will throw exception (#1302) fix-1280 Co-authored-by: jinsilei <[email protected]>
apache · Mar 30, 2023 · 3a0afe0 · 3a0afe0
1 parent 3e99443
commit 3a0afe0
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/spark/v3.1/spark/src/main/java/com/netease/arctic/spark/ArcticSparkSessionCatalog.java b/spark/v3.1/spark/src/main/java/com/netease/arctic/spark/ArcticSparkSessionCatalog.java
@@ -177,6 +177,11 @@ public void renameTable(Identifier from, Identifier to) throws NoSuchTableExcept
   public final void initialize(String name, CaseInsensitiveStringMap options) {
     this.catalogName = name;
     this.options = options;
+    try {
+      this.arcticCatalog = buildSparkCatalog(name, options);
+    } catch (Exception e) {
+      this.arcticCatalog = null;
+    }
   }
 
   @Override