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 <[email protected]>
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() {
   }

Reply via email to