Core: Fix NPE when calling InMemoryLockManager#release using Hadoop c…

…atalog (#8494)
apache · Oct 30, 2023 · 64e2deb · 64e2deb
1 parent 8bb52bc
commit 64e2deb
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/core/src/main/java/org/apache/iceberg/util/LockManagers.java b/core/src/main/java/org/apache/iceberg/util/LockManagers.java
@@ -19,6 +19,7 @@
 package org.apache.iceberg.util;
 
 import java.util.Map;
+import java.util.Optional;
 import java.util.concurrent.Executors;
 import java.util.concurrent.ScheduledExecutorService;
 import java.util.concurrent.ScheduledFuture;
@@ -253,7 +254,7 @@ public boolean release(String entityId, String ownerId) {
         return false;
       }
 
-      HEARTBEATS.remove(entityId).cancel(false);
+      Optional.ofNullable(HEARTBEATS.remove(entityId)).ifPresent(future -> future.cancel(false));
       LOCKS.remove(entityId);
       return true;
     }