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

[fix](pipelineX) fix error set delta_urls (#25631)

Browse Source
This commit is contained in:
Mryange
2023-10-19 19:27:31 +08:00
committed by GitHub
parent 7385602b19
commit b0e70bd02b
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
be/src/runtime/fragment_mgr.cpp
View File

@ -266,12 +266,14 @@ void FragmentMgr::coordinator_callback(const ReportStatusRequest& req) {
params.delta_urls.push_back(to_http_path(it));
}
} else if (!req.runtime_states.empty()) {
params.__isset.delta_urls = true;
for (auto* rs : req.runtime_states) {
for (auto& it : rs->output_files()) {
params.delta_urls.push_back(to_http_path(it));
}
}
if (!params.delta_urls.empty()) {
params.__isset.delta_urls = true;
}
}
if (req.runtime_state->num_rows_load_total() > 0 ||
req.runtime_state->num_rows_load_filtered() > 0) {