AWS: Close underlying scheduler for DynamoDbLockManager (apache#10132)

geruh · Apr 15, 2024 · d067677 · d067677
1 parent e6a1a45
commit d067677
Showing 1 changed file with 3 additions and 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
@@ -312,10 +312,12 @@ private static Map<String, AttributeValue> toLockIdValues(String entityId, Strin
   }
 
   @Override
-  public void close() {
+  public void close() throws Exception {
     dynamo.close();
     heartbeats.values().forEach(DynamoDbHeartbeat::cancel);
     heartbeats.clear();
+
+    super.close();
   }
 
   /**