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

[fix](load) fix new_load_scan_node load finished but no data actually caused by wrong file size (#15211)

Browse Source
This commit is contained in:
luozenglin
2022-12-22 09:28:00 +08:00
committed by GitHub
parent 1cc79510c9
commit cc995c4307
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
fe/fe-core/src/main/java/org/apache/doris/planner/external/FileGroupInfo.java vendored
View File

@ -307,6 +307,7 @@ public class FileGroupInfo {
rangeDesc.setPath(fileStatus.path);
rangeDesc.setStartOffset(curFileOffset);
rangeDesc.setSize(rangeBytes);
rangeDesc.setFileSize(fileStatus.size);
rangeDesc.setColumnsFromPath(columnsFromPath);
} else {
// for stream load
@ -316,10 +317,10 @@ public class FileGroupInfo {
Preconditions.checkState(fileGroup.getFilePaths().size() == 1);
rangeDesc.setPath(fileGroup.getFilePaths().get(0));
rangeDesc.setStartOffset(0);
rangeDesc.setSize(fileStatus.size);
}
rangeDesc.setLoadId(loadId);
rangeDesc.setSize(fileStatus.size);
rangeDesc.setFileSize(fileStatus.size);
}
return rangeDesc;
}