This is an automated email from the ASF dual-hosted git repository.
amoghj pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/iceberg.git
The following commit(s) were added to refs/heads/main by this push:
new d067677df8 AWS: Close underlying scheduler for DynamoDbLockManager
(#10132)
d067677df8 is described below
commit d067677df8cf86bb2161f5dea16a078e99540566
Author: Filipe Regadas <[email protected]>
AuthorDate: Mon Apr 15 18:06:10 2024 +0100
AWS: Close underlying scheduler for DynamoDbLockManager (#10132)
---
.../java/org/apache/iceberg/aws/dynamodb/DynamoDbLockManager.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git
a/aws/src/main/java/org/apache/iceberg/aws/dynamodb/DynamoDbLockManager.java
b/aws/src/main/java/org/apache/iceberg/aws/dynamodb/DynamoDbLockManager.java
index 252ce10a7c..80bbfcbee7 100644
--- a/aws/src/main/java/org/apache/iceberg/aws/dynamodb/DynamoDbLockManager.java
+++ b/aws/src/main/java/org/apache/iceberg/aws/dynamodb/DynamoDbLockManager.java
@@ -312,10 +312,12 @@ public class DynamoDbLockManager extends
LockManagers.BaseLockManager {
}
@Override
- public void close() {
+ public void close() throws Exception {
dynamo.close();
heartbeats.values().forEach(DynamoDbHeartbeat::cancel);
heartbeats.clear();
+
+ super.close();
}
/**