tool
/
starrocks
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

[BugFix] Fix missing clone copy size and duration (backport #62074) (#62108) 

Signed-off-by: wyb <wybb86@gmail.com>
Co-authored-by: wyb <wybb86@gmail.com>
This commit is contained in:
mergify[bot] 2025-08-19 13:42:17 +00:00 committed by GitHub
parent 7b3f2789b9
commit 945d51a80b
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
3 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
be/src/agent/agent_task.cpp
View File

@ -412,6 +412,8 @@ void run_clone_task(const std::shared_ptr<CloneAgentTaskRequest>& agent_task_req
LOG(INFO) << "clone success, set tablet infos. status:" << status
<< ", signature:" << agent_task_req->signature;
finish_task_request.__set_finish_tablet_infos(tablet_infos);
finish_task_request.__set_copy_size(engine_task.get_copy_size());
finish_task_request.__set_copy_time_ms(engine_task.get_copy_time_ms());
}
}
}

2
be/src/storage/task/engine_clone_task.cpp
View File

@ -655,6 +655,8 @@ Status EngineCloneTask::_download_files(DataDir* data_dir, const std::string& re
if (total_time_ms > 0) {
copy_rate = total_file_size / ((double)total_time_ms) / 1000;
}
_copy_size = (int64_t)total_file_size;
_copy_time_ms = (int64_t)total_time_ms;
LOG(INFO) << "Copied tablet " << _signature << " files=" << file_name_list.size() << ". bytes=" << total_file_size
<< " cost=" << total_time_ms << " ms"
<< " rate=" << copy_rate << " MB/s";

5
be/src/storage/task/engine_clone_task.h
View File

@ -57,6 +57,9 @@ public:
Status execute() override;
int64_t get_copy_size() const { return _copy_size; }
int64_t get_copy_time_ms() const { return _copy_time_ms; }
private:
Status _do_clone_primary_tablet(Tablet* tablet);
@ -95,6 +98,8 @@ private:
vector<TTabletInfo>* _tablet_infos;
AgentStatus* _res_status;
int64_t _signature;
int64_t _copy_size = 0;
int64_t _copy_time_ms = 0;
}; // EngineTask
} // namespace starrocks