From de4242cafc0ee0dd7689cc9b72f142f06071ce65 Mon Sep 17 00:00:00 2001
From: hailin0 <wanghailin@apache.org>
Date: Wed, 3 Apr 2024 15:58:58 +0800
Subject: [PATCH] [E2E] Fix AmazondynamodbIT unstable (#6640)

---
 .../e2e/connector/amazondynamodb/AmazondynamodbIT.java        | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-amazondynamodb-e2e/src/test/java/org/apache/seatunnel/e2e/connector/amazondynamodb/AmazondynamodbIT.java b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-amazondynamodb-e2e/src/test/java/org/apache/seatunnel/e2e/connector/amazondynamodb/AmazondynamodbIT.java
index 5ae72f6d956..020d510b442 100644
--- a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-amazondynamodb-e2e/src/test/java/org/apache/seatunnel/e2e/connector/amazondynamodb/AmazondynamodbIT.java
+++ b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-amazondynamodb-e2e/src/test/java/org/apache/seatunnel/e2e/connector/amazondynamodb/AmazondynamodbIT.java
@@ -171,7 +171,9 @@ private void clearSinkTable() {
     }
 
     private void assertHasData(String tableName) {
-        ScanResponse scan = dynamoDbClient.scan(ScanRequest.builder().tableName(tableName).build());
+        ScanResponse scan =
+                dynamoDbClient.scan(
+                        ScanRequest.builder().tableName(tableName).consistentRead(true).build());
         Assertions.assertTrue(
                 !scan.items().isEmpty(), String.format("table %s is empty.", tableName));
     }