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