You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iceberg.apache.org by ja...@apache.org on 2022/05/25 05:19:21 UTC
[iceberg] branch master updated: AWS: Use strongly consistent read in DDBLockManager (#4763)
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 <35...@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());