From 83fb372a14bc0a69b04c2a710dc527b6c2e1ddbe Mon Sep 17 00:00:00 2001 From: okumin Date: Tue, 17 Jun 2025 18:45:40 +0900 Subject: [PATCH 1/2] HIVE-29016: Disable caching on the Iceberg REST Catalog --- .../org/apache/hadoop/hive/metastore/conf/MetastoreConf.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/standalone-metastore/metastore-common/src/main/java/org/apache/hadoop/hive/metastore/conf/MetastoreConf.java b/standalone-metastore/metastore-common/src/main/java/org/apache/hadoop/hive/metastore/conf/MetastoreConf.java index 7b602e2e8e62..f5c58cb7e9ad 100644 --- a/standalone-metastore/metastore-common/src/main/java/org/apache/hadoop/hive/metastore/conf/MetastoreConf.java +++ b/standalone-metastore/metastore-common/src/main/java/org/apache/hadoop/hive/metastore/conf/MetastoreConf.java @@ -1872,7 +1872,7 @@ public enum ConfVars { "HMS Iceberg Catalog servlet authentication method (simple or jwt)." ), ICEBERG_CATALOG_CACHE_EXPIRY("metastore.iceberg.catalog.cache.expiry", - "hive.metastore.iceberg.catalog.cache.expiry", 60_000L, + "hive.metastore.iceberg.catalog.cache.expiry", -1, "HMS Iceberg Catalog cache expiry." ), HTTPSERVER_THREADPOOL_MIN("hive.metastore.httpserver.threadpool.min", From 2e9e9dc21b6391e29e492b2621d75637f95b5ba4 Mon Sep 17 00:00:00 2001 From: okumin Date: Fri, 20 Jun 2025 21:33:29 +0900 Subject: [PATCH 2/2] Override buildTable --- .../java/org/apache/iceberg/rest/HMSCachingCatalog.java | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/standalone-metastore/metastore-rest-catalog/src/main/java/org/apache/iceberg/rest/HMSCachingCatalog.java b/standalone-metastore/metastore-rest-catalog/src/main/java/org/apache/iceberg/rest/HMSCachingCatalog.java index 6b5d76f818a8..c57e4fb8c19a 100644 --- a/standalone-metastore/metastore-rest-catalog/src/main/java/org/apache/iceberg/rest/HMSCachingCatalog.java +++ b/standalone-metastore/metastore-rest-catalog/src/main/java/org/apache/iceberg/rest/HMSCachingCatalog.java @@ -24,6 +24,7 @@ import java.util.Map; import java.util.Set; import org.apache.iceberg.CachingCatalog; +import org.apache.iceberg.Schema; import org.apache.iceberg.catalog.Catalog; import org.apache.iceberg.catalog.Namespace; import org.apache.iceberg.catalog.SupportsNamespaces; @@ -48,6 +49,11 @@ public CATALOG hmsUnwrap() { return nsCatalog; } + @Override + public Catalog.TableBuilder buildTable(TableIdentifier identifier, Schema schema) { + return nsCatalog.buildTable(identifier, schema); + } + @Override public void createNamespace(Namespace nmspc, Map map) { nsCatalog.createNamespace(nmspc, map);