You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iceberg.apache.org by ao...@apache.org on 2021/03/24 18:41:33 UTC
[iceberg] 18/18: Spark: Remove softValues for Spark 2 catalog cache
(#2363)
This is an automated email from the ASF dual-hosted git repository.
aokolnychyi pushed a commit to branch 0.11.x
in repository https://gitbox.apache.org/repos/asf/iceberg.git
commit aba388116ac84980ff6e6ec378c16dcd3b4bf4ca
Author: Sam Pringle <pr...@hey.com>
AuthorDate: Wed Mar 24 14:29:56 2021 -0400
Spark: Remove softValues for Spark 2 catalog cache (#2363)
---
.../src/main/java/org/apache/iceberg/spark/source/CustomCatalogs.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
diff --git a/spark2/src/main/java/org/apache/iceberg/spark/source/CustomCatalogs.java b/spark2/src/main/java/org/apache/iceberg/spark/source/CustomCatalogs.java
index 742cac5..54e1748 100644
--- a/spark2/src/main/java/org/apache/iceberg/spark/source/CustomCatalogs.java
+++ b/spark2/src/main/java/org/apache/iceberg/spark/source/CustomCatalogs.java
@@ -39,8 +39,7 @@ import org.apache.spark.SparkConf;
import org.apache.spark.sql.SparkSession;
public final class CustomCatalogs {
- private static final Cache<Pair<SparkSession, String>, Catalog> CATALOG_CACHE = Caffeine.newBuilder()
- .softValues().build();
+ private static final Cache<Pair<SparkSession, String>, Catalog> CATALOG_CACHE = Caffeine.newBuilder().build();
public static final String ICEBERG_DEFAULT_CATALOG = "default_catalog";
public static final String ICEBERG_CATALOG_PREFIX = "spark.sql.catalog";