Core: Handle potential NPE in RESTSessionCatalog#newSessionCache (apa…

…che#10607) Signed-off-by: Tai Le Manh <manhtai.lmt@gmail.com>
hililiwei · Jul 2, 2024 · f4ddaea · f4ddaea
1 parent d3cb1b6
commit f4ddaea
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/core/src/main/java/org/apache/iceberg/rest/RESTSessionCatalog.java b/core/src/main/java/org/apache/iceberg/rest/RESTSessionCatalog.java
@@ -1049,7 +1049,12 @@ private static Cache<String, AuthSession> newSessionCache(Map<String, String> pr
     return Caffeine.newBuilder()
         .expireAfterAccess(Duration.ofMillis(expirationIntervalMs))
         .removalListener(
-            (RemovalListener<String, AuthSession>) (id, auth, cause) -> auth.stopRefreshing())
+            (RemovalListener<String, AuthSession>)
+                (id, auth, cause) -> {
+                  if (auth != null) {
+                    auth.stopRefreshing();
+                  }
+                })
         .build();
   }