database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[Improvement] broker load with hdfs support wildcard (#8718)

Browse Source 
broker load with hdfs support wildcard
This commit is contained in:
dataalive
2022-03-29 18:21:41 +08:00
committed by GitHub
parent 1ddfe20950
commit 3f5bc5206d
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
fe/fe-core/src/main/java/org/apache/doris/common/util/BrokerUtil.java
View File

@ -187,7 +187,7 @@ public class BrokerUtil {
}
try {
FileSystem fs = FileSystem.get(new URI(hdfsFsName), conf, user);
FileStatus[] statusList = fs.listStatus(new Path(path));
FileStatus[] statusList = fs.globStatus(new Path(path));
for (FileStatus status : statusList) {
if (status.isFile()) {
fileStatuses.add(new TBrokerFileStatus(status.getPath().toUri().getPath(),