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 39c510d682e9 fix: ensure AmazonDynamoDBLockClient is always closed in 
DynamoDBBasedLockProviderBase.close() (#19742)
39c510d682e9 is described below

commit 39c510d682e9014f7c776937379b23bd459e5ceb
Author: Venkateswarlu Boggavarapu <[email protected]>
AuthorDate: Wed Aug 26 00:42:35 2026 -0400

    fix: ensure AmazonDynamoDBLockClient is always closed in 
DynamoDBBasedLockProviderBase.close() (#19742)
    
    * fix: ensure AmazonDynamoDBLockClient is always closed in 
DynamoDBBasedLockProviderBase.close()
---
 .../hudi/aws/transaction/lock/DynamoDBBasedLockProviderBase.java   | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git 
a/hudi-aws/src/main/java/org/apache/hudi/aws/transaction/lock/DynamoDBBasedLockProviderBase.java
 
b/hudi-aws/src/main/java/org/apache/hudi/aws/transaction/lock/DynamoDBBasedLockProviderBase.java
index 2deccd27a993..b99639f24c39 100644
--- 
a/hudi-aws/src/main/java/org/apache/hudi/aws/transaction/lock/DynamoDBBasedLockProviderBase.java
+++ 
b/hudi-aws/src/main/java/org/apache/hudi/aws/transaction/lock/DynamoDBBasedLockProviderBase.java
@@ -150,9 +150,14 @@ public abstract class DynamoDBBasedLockProviderBase 
implements LockProvider<Lock
         }
         lock = null;
       }
-      this.client.close();
     } catch (Exception e) {
       LOG.error(generateLogStatement(LockState.FAILED_TO_RELEASE, 
generateLogSuffixString()));
+    } finally {
+      try {
+        this.client.close();
+      } catch (Exception ex) {
+        LOG.warn("Failed to close AmazonDynamoDBLockClient after failed lock 
release", ex);
+      }
     }
   }
 

Reply via email to