[iceberg] branch master updated: AWS: Use strongly consistent read in DDBLockManager (#4763)

[jackye]

This is an automated email from the ASF dual-hosted git repository.

jackye pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iceberg.git


The following commit(s) were added to refs/heads/master by this push:
     new 815226b0f AWS: Use strongly consistent read in DDBLockManager (#4763)
815226b0f is described below

commit 815226b0f184d1bb95ba1d62765f79cd3355d0e1
Author: Prashant Singh <35593236+singhpk...@users.noreply.github.com>
AuthorDate: Wed May 25 10:49:14 2022 +0530

    AWS: Use strongly consistent read in DDBLockManager (#4763)
---
 .../main/java/org/apache/iceberg/aws/dynamodb/DynamoDbLockManager.java   | 1 +
 1 file changed, 1 insertion(+)

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 f13c28849..8ed40d18d 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
@@ -200,6 +200,7 @@ public class DynamoDbLockManager extends 
LockManagers.BaseLockManager {
   void acquireOnce(String entityId, String ownerId) {
     GetItemResponse response = dynamo.getItem(GetItemRequest.builder()
         .tableName(lockTableName)
+        .consistentRead(true)
         .key(toKey(entityId))
         .build());