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();
}
}