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

Reply via email to