You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iceberg.apache.org by bl...@apache.org on 2020/10/28 23:10:16 UTC
[iceberg] branch master updated: Spark: Remove cache expiration in
HiveCatalogs cache (#1674)
This is an automated email from the ASF dual-hosted git repository.
blue pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iceberg.git
The following commit(s) were added to refs/heads/master by this push:
new b1c94dc Spark: Remove cache expiration in HiveCatalogs cache (#1674)
b1c94dc is described below
commit b1c94dca0cec30cf30864bc891a7dea1507b2cc7
Author: Ryan Blue <bl...@apache.org>
AuthorDate: Wed Oct 28 16:10:06 2020 -0700
Spark: Remove cache expiration in HiveCatalogs cache (#1674)
---
.../src/main/java/org/apache/iceberg/hive/HiveCatalogs.java | 7 +------
1 file changed, 1 insertion(+), 6 deletions(-)
diff --git a/hive-metastore/src/main/java/org/apache/iceberg/hive/HiveCatalogs.java b/hive-metastore/src/main/java/org/apache/iceberg/hive/HiveCatalogs.java
index b21ea62..fbe934e 100644
--- a/hive-metastore/src/main/java/org/apache/iceberg/hive/HiveCatalogs.java
+++ b/hive-metastore/src/main/java/org/apache/iceberg/hive/HiveCatalogs.java
@@ -21,17 +21,12 @@ package org.apache.iceberg.hive;
import com.github.benmanes.caffeine.cache.Cache;
import com.github.benmanes.caffeine.cache.Caffeine;
-import com.github.benmanes.caffeine.cache.RemovalListener;
-import java.util.concurrent.TimeUnit;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hive.conf.HiveConf;
public final class HiveCatalogs {
- private static final Cache<String, HiveCatalog> CATALOG_CACHE = Caffeine.newBuilder()
- .expireAfterAccess(10, TimeUnit.MINUTES)
- .removalListener((RemovalListener<String, HiveCatalog>) (uri, catalog, cause) -> catalog.close())
- .build();
+ private static final Cache<String, HiveCatalog> CATALOG_CACHE = Caffeine.newBuilder().build();
private HiveCatalogs() {
}