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)); }