This is an automated email from the ASF dual-hosted git repository.

danny0405 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git


The following commit(s) were added to refs/heads/master by this push:
     new fe716f1f5b58 fix: ensure CuratorFramework is always closed in 
BaseZookeeperBasedLockProvider.close() (#19741)
fe716f1f5b58 is described below

commit fe716f1f5b585ac79a027811f7a8a2ca6944e234
Author: Venkateswarlu Boggavarapu <[email protected]>
AuthorDate: Wed Aug 26 00:13:13 2026 -0400

    fix: ensure CuratorFramework is always closed in 
BaseZookeeperBasedLockProvider.close() (#19741)
    
    Ensure curatorFrameworkClient is closed in the finally block to prevent 
resource leaks.
---
 .../hudi/client/transaction/lock/BaseZookeeperBasedLockProvider.java   | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/transaction/lock/BaseZookeeperBasedLockProvider.java
 
b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/transaction/lock/BaseZookeeperBasedLockProvider.java
index 6cdee60e2d1b..53024352f623 100644
--- 
a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/transaction/lock/BaseZookeeperBasedLockProvider.java
+++ 
b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/transaction/lock/BaseZookeeperBasedLockProvider.java
@@ -185,9 +185,10 @@ public abstract class BaseZookeeperBasedLockProvider 
implements LockProvider<Int
         lock.release();
         lock = null;
       }
-      this.curatorFrameworkClient.close();
     } catch (Exception e) {
       log.error(generateLogStatement(LockState.FAILED_TO_RELEASE, 
generateLogSuffixString()));
+    } finally {
+      this.curatorFrameworkClient.close();
     }
   }
 

Reply via email to