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";