This is an automated email from the ASF dual-hosted git repository.
yangzhg pushed a commit to branch branch-1.2-lts
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-1.2-lts by this push:
new 13e65e6c52 [fix](brokerload) fix broker load failed aused by the error
path (#15057) (#15236)
13e65e6c52 is described below
commit 13e65e6c522c38c7cfa22b648af5b7b722ba322a
Author: luozenglin <[email protected]>
AuthorDate: Wed Dec 21 15:27:52 2022 +0800
[fix](brokerload) fix broker load failed aused by the error path (#15057)
(#15236)
---
fe/fe-core/src/main/java/org/apache/doris/backup/BrokerStorage.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/backup/BrokerStorage.java
b/fe/fe-core/src/main/java/org/apache/doris/backup/BrokerStorage.java
index de6eefb5c0..9a02d0ba47 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/backup/BrokerStorage.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/backup/BrokerStorage.java
@@ -512,7 +512,6 @@ public class BrokerStorage extends BlobStorage {
}
// List files in remotePath
- // The remote file name will only contains file name only(Not full path)
@Override
public Status list(String remotePath, List<RemoteFile> result, boolean
fileNameOnly) {
// get a proper broker
@@ -528,7 +527,7 @@ public class BrokerStorage extends BlobStorage {
try {
TBrokerListPathRequest req = new
TBrokerListPathRequest(TBrokerVersion.VERSION_ONE, remotePath,
false /* not recursive */, getProperties());
- req.setFileNameOnly(true);
+ req.setFileNameOnly(fileNameOnly);
TBrokerListResponse rep = client.listPath(req);
TBrokerOperationStatus opst = rep.getOpStatus();
if (opst.getStatusCode() != TBrokerOperationStatusCode.OK) {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
