>From Michael Blow <[email protected]>:

Michael Blow has uploaded this change for review. ( 
https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/19732 )


Change subject: [NO ISSUE][*DB][STO] Fix gate for 
CLOUD_STORAGE_LIST_EVENTUALLY_CONSISTENT
......................................................................

[NO ISSUE][*DB][STO] Fix gate for CLOUD_STORAGE_LIST_EVENTUALLY_CONSISTENT

Correct inverted check to validate list results when the
CLOUD_STORAGE_LIST_EVENTUALLY_CONSISTENT is configured true

Ext-ref: MB-66343
Change-Id: I561975e684a02a92cd05ddaadf88e1a4ee56c899
---
M 
asterixdb/asterix-cloud/src/main/java/org/apache/asterix/cloud/clients/aws/s3/S3CloudClient.java
1 file changed, 14 insertions(+), 1 deletion(-)



  git pull ssh://asterix-gerrit.ics.uci.edu:29418/asterixdb 
refs/changes/32/19732/1

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 77d34a2..fc35792 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 @@

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

--
To view, visit https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/19732
To unsubscribe, or for help writing mail filters, visit 
https://asterix-gerrit.ics.uci.edu/settings

Gerrit-Project: asterixdb
Gerrit-Branch: master
Gerrit-Change-Id: I561975e684a02a92cd05ddaadf88e1a4ee56c899
Gerrit-Change-Number: 19732
Gerrit-PatchSet: 1
Gerrit-Owner: Michael Blow <[email protected]>
Gerrit-MessageType: newchange

Reply via email to