(seatunnel) branch dev updated: [E2E] Fix AmazondynamodbIT unstable (#6640)

[zhouyao2023]

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

zhouyao2023 pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new de4242cafc [E2E] Fix AmazondynamodbIT unstable (#6640)
de4242cafc is described below

commit de4242cafc0ee0dd7689cc9b72f142f06071ce65
Author: hailin0 <wanghai...@apache.org>
AuthorDate: Wed Apr 3 15:58:58 2024 +0800

    [E2E] Fix AmazondynamodbIT unstable (#6640)
---
 .../seatunnel/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 5ae72f6d95..020d510b44 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 @@ public class AmazondynamodbIT extends TestSuiteBase 
implements TestResource {
     }
 
     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));
     }