[E2E] Fix AmazondynamodbIT unstable (#6640)

hailin0 · web-flow · commit de4242cafc0e · 2024-04-03T15:58:58.000+08:00
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
@@ -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));
     }

Original file line number	Diff line number	Diff line change
`@@ -171,7 +171,9 @@ private void clearSinkTable() {`
`171`	`171`	`}`
`172`	`172`
`173`	`173`	`private void assertHasData(String tableName) {`
`174`		`- ScanResponse scan = dynamoDbClient.scan(ScanRequest.builder().tableName(tableName).build());`
	`174`	`+ ScanResponse scan =`
	`175`	`+ dynamoDbClient.scan(`
	`176`	`+ ScanRequest.builder().tableName(tableName).consistentRead(true).build());`
`175`	`177`	`Assertions.assertTrue(`
`176`	`178`	`!scan.items().isEmpty(), String.format("table %s is empty.", tableName));`
`177`	`179`	`}`