This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 1e09c399ede [fix](Azure) Correct the truncated condition for Azure's
list in FE (#37986)
1e09c399ede is described below
commit 1e09c399eded2f9d1d9380cf3e06c844842eba16
Author: AlexYue <yj976240...@gmail.com>
AuthorDate: Wed Jul 17 23:16:05 2024 +0800
[fix](Azure) Correct the truncated condition for Azure's list in FE (#37986)
## Proposed changes
<!--Describe your changes.-->
---
.../src/main/java/org/apache/doris/cloud/storage/AzureRemote.java | 2 +-
fe/fe-core/src/main/java/org/apache/doris/fs/obj/AzureObjStorage.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/cloud/storage/AzureRemote.java
b/fe/fe-core/src/main/java/org/apache/doris/cloud/storage/AzureRemote.java
index 0dc0cf60019..19629096737 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/cloud/storage/AzureRemote.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/cloud/storage/AzureRemote.java
@@ -212,7 +212,7 @@ public class AzureRemote extends RemoteBase {
objectFiles.add(new ObjectFile(blobItem.getName(),
getRelativePath(blobItem.getName()),
blobItem.getProperties().getETag(),
blobItem.getProperties().getContentLength()));
}
- return new ListObjectsResult(objectFiles,
pagedResponse.getContinuationToken() == null,
+ return new ListObjectsResult(objectFiles,
pagedResponse.getContinuationToken() != null,
pagedResponse.getContinuationToken());
} catch (BlobStorageException e) {
LOG.warn("Failed to list objects for Azure", e);
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/fs/obj/AzureObjStorage.java
b/fe/fe-core/src/main/java/org/apache/doris/fs/obj/AzureObjStorage.java
index 73d9444cc8a..fb76ed20a45 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/fs/obj/AzureObjStorage.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/fs/obj/AzureObjStorage.java
@@ -280,7 +280,7 @@ public class AzureObjStorage implements
ObjStorage<BlobServiceClient> {
remoteObjects.add(new RemoteObject(blobItem.getName(), "",
blobItem.getProperties().getETag(),
blobItem.getProperties().getContentLength()));
}
- return new RemoteObjects(remoteObjects,
pagedResponse.getContinuationToken() == null,
+ return new RemoteObjects(remoteObjects,
pagedResponse.getContinuationToken() != null,
pagedResponse.getContinuationToken());
} catch (BlobStorageException e) {
LOG.warn(String.format("Failed to list objects for S3: %s",
remotePath), e);
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
