[E2E] Fix AmazondynamodbIT unstable (apache#6640)

JNSimba · Apr 3, 2024 · de4242c · de4242c
1 parent 80f392a
commit de4242c
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/...e2e/src/test/java/org/apache/seatunnel/e2e/connector/amazondynamodb/AmazondynamodbIT.java b/...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));
     }