caching limit

apache · Sep 12, 2024 · 1c03cd1 · 1c03cd1
1 parent 6e7de37
commit 1c03cd1
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/core/src/main/java/org/apache/iceberg/encryption/StandardEncryptionManager.java b/core/src/main/java/org/apache/iceberg/encryption/StandardEncryptionManager.java
@@ -54,7 +54,8 @@ private TransientEncryptionState(KeyManagementClient kmsClient) {
       this.encryptionKeys = Maps.newLinkedHashMap();
       this.unwrappedKeyCache =
           Caffeine.newBuilder()
-              .expireAfterWrite(1, TimeUnit.MINUTES)
+              .maximumSize(1000)
+              .expireAfterWrite(1, TimeUnit.DAYS)
               .build(wrappedKey -> kmsClient.unwrapKey(wrappedKey, tableKeyId));
       this.currentEncryptionKey = null;
     }