You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by mo...@apache.org on 2022/12/22 08:55:56 UTC
[doris] 03/05: [fix](load) fix new_load_scan_node load finished but no data actually caused by wrong file size (#15211)
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 <37...@users.noreply.github.com>
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: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org