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

preetham02 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/asterixdb.git


The following commit(s) were added to refs/heads/master by this push:
     new e089c94432 [NO ISSUE][*DB][STO] Fix gate for cloud list eventually 
consistent check
e089c94432 is described below

commit e089c944329fdc4cd2d7b51b70f77da03f8acdbf
Author: Michael Blow <[email protected]>
AuthorDate: Fri May 2 07:44:45 2025 -0400

    [NO ISSUE][*DB][STO] Fix gate for cloud list eventually consistent check
    
    Correct inverted check to validate list results when the
    CLOUD_STORAGE_LIST_EVENTUALLY_CONSISTENT option is configured true
    
    Ext-ref: MB-66343
    Change-Id: I561975e684a02a92cd05ddaadf88e1a4ee56c899
    Reviewed-on: https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/19732
    Reviewed-by: Michael Blow <[email protected]>
    Reviewed-by: Ritik Raj <[email protected]>
    Tested-by: Michael Blow <[email protected]>
---
 .../java/org/apache/asterix/cloud/clients/aws/s3/S3CloudClient.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/asterixdb/asterix-cloud/src/main/java/org/apache/asterix/cloud/clients/aws/s3/S3CloudClient.java
 
b/asterixdb/asterix-cloud/src/main/java/org/apache/asterix/cloud/clients/aws/s3/S3CloudClient.java
index 77d34a2f4a..fc35792402 100644
--- 
a/asterixdb/asterix-cloud/src/main/java/org/apache/asterix/cloud/clients/aws/s3/S3CloudClient.java
+++ 
b/asterixdb/asterix-cloud/src/main/java/org/apache/asterix/cloud/clients/aws/s3/S3CloudClient.java
@@ -371,7 +371,7 @@ public final class S3CloudClient implements ICloudClient {
 
     private <T, C extends Collection<T>> C ensureListConsistent(C cloudFiles, 
String bucket,
             Function<T, String> pathExtractor) {
-        if (config.isStorageListEventuallyConsistent()) {
+        if (!config.isStorageListEventuallyConsistent()) {
             return cloudFiles;
         }
         Iterator<T> iterator = cloudFiles.iterator();

Reply via email to