AWS: Use strongly consistent read in DDBLockManager (#4763)

apache · May 25, 2022 · 815226b0f184d1bb95ba1d62765f79cd3355d0e1 · 815226b
1 parent 49684ac
commit 815226b0f184d1bb95ba1d62765f79cd3355d0e1
Showing 1 changed file with 1 addition and 0 deletions.
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
@@ -200,6 +200,7 @@ public boolean acquire(String entityId, String ownerId) {
   void acquireOnce(String entityId, String ownerId) {
     GetItemResponse response = dynamo.getItem(GetItemRequest.builder()
         .tableName(lockTableName)
+        .consistentRead(true)
         .key(toKey(entityId))
         .build());