This is an automated email from the ASF dual-hosted git repository. morningman pushed a commit to branch branch-1.2-lts in repository https://gitbox.apache.org/repos/asf/doris.git
commit 913b525b90341c539c4158e028c3800436abd892 Author: luozenglin <[email protected]> AuthorDate: Thu Dec 22 09:28:00 2022 +0800 [fix](load) fix new_load_scan_node load finished but no data actually caused by wrong file size (#15211) --- .../src/main/java/org/apache/doris/planner/external/FileGroupInfo.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/fe/fe-core/src/main/java/org/apache/doris/planner/external/FileGroupInfo.java b/fe/fe-core/src/main/java/org/apache/doris/planner/external/FileGroupInfo.java index 0a2f3edb8e..a33b4787d5 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/planner/external/FileGroupInfo.java +++ b/fe/fe-core/src/main/java/org/apache/doris/planner/external/FileGroupInfo.java @@ -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; } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
