This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-3.0 by this push:
new 5052f9029bc branch-3.0: [fix](load): fix incorrect progress on
finished loads #55509 (#55529)
5052f9029bc is described below
commit 5052f9029bc27f327e907d127069b8f3229ce893
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Mon Sep 1 19:10:04 2025 +0800
branch-3.0: [fix](load): fix incorrect progress on finished loads #55509
(#55529)
Cherry-picked from #55509
Co-authored-by: Kaijie Chen <[email protected]>
---
be/src/runtime/fragment_mgr.cpp | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/be/src/runtime/fragment_mgr.cpp b/be/src/runtime/fragment_mgr.cpp
index 3f51331346d..9ba558be76d 100644
--- a/be/src/runtime/fragment_mgr.cpp
+++ b/be/src/runtime/fragment_mgr.cpp
@@ -437,7 +437,7 @@ void FragmentMgr::coordinator_callback(const
ReportStatusRequest& req) {
} else if (!req.runtime_states.empty()) {
for (auto* rs : req.runtime_states) {
if (rs->num_rows_load_total() > 0 || rs->num_rows_load_filtered()
> 0 ||
- req.runtime_state->num_finished_range() > 0) {
+ rs->num_finished_range() > 0) {
params.__isset.load_counters = true;
num_rows_load_success += rs->num_rows_load_success();
num_rows_load_filtered += rs->num_rows_load_filtered();
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
