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() {
}