You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by yi...@apache.org on 2026/04/13 08:58:09 UTC
(doris) branch branch-4.1 updated: branch-4.1: [fix](be) Add missing SCOPED_ATTACH_TASK in download and move_dir callbacks #62403 (#62424)
This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-4.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-4.1 by this push:
new a5e30e067d3 branch-4.1: [fix](be) Add missing SCOPED_ATTACH_TASK in download and move_dir callbacks #62403 (#62424)
a5e30e067d3 is described below
commit a5e30e067d32261e05ebf7505a5fe137eb0fdbb3
Author: github-actions[bot] <41...@users.noreply.github.com>
AuthorDate: Mon Apr 13 16:58:01 2026 +0800
branch-4.1: [fix](be) Add missing SCOPED_ATTACH_TASK in download and move_dir callbacks #62403 (#62424)
Cherry-picked from #62403
Co-authored-by: Qi Chen <ch...@selectdb.com>
---
be/src/agent/task_worker_pool.cpp | 4 ++++
1 file changed, 4 insertions(+)
diff --git a/be/src/agent/task_worker_pool.cpp b/be/src/agent/task_worker_pool.cpp
index c07c844160d..a002f52ff70 100644
--- a/be/src/agent/task_worker_pool.cpp
+++ b/be/src/agent/task_worker_pool.cpp
@@ -1330,12 +1330,14 @@ void download_callback(StorageEngine& engine, ExecEnv* env, const TAgentTaskRequ
if (download_request.__isset.remote_tablet_snapshots) {
std::unique_ptr<SnapshotLoader> loader = std::make_unique<SnapshotLoader>(
engine, env, download_request.job_id, req.signature);
+ SCOPED_ATTACH_TASK(loader->resource_ctx());
status = loader->remote_http_download(download_request.remote_tablet_snapshots,
&downloaded_tablet_ids);
} else {
std::unique_ptr<SnapshotLoader> loader = std::make_unique<SnapshotLoader>(
engine, env, download_request.job_id, req.signature, download_request.broker_addr,
download_request.broker_prop);
+ SCOPED_ATTACH_TASK(loader->resource_ctx());
status = loader->init(download_request.__isset.storage_backend
? download_request.storage_backend
: TStorageBackendType::type::BROKER,
@@ -1383,6 +1385,7 @@ void download_callback(CloudStorageEngine& engine, ExecEnv* env, const TAgentTas
std::unique_ptr<CloudSnapshotLoader> loader = std::make_unique<CloudSnapshotLoader>(
engine, env, download_request.job_id, req.signature, download_request.broker_addr,
download_request.broker_prop);
+ SCOPED_ATTACH_TASK(loader->resource_ctx());
status = loader->init(download_request.__isset.storage_backend
? download_request.storage_backend
: TStorageBackendType::type::BROKER,
@@ -1536,6 +1539,7 @@ void move_dir_callback(StorageEngine& engine, ExecEnv* env, const TAgentTaskRequ
status = Status::InvalidArgument("Could not find tablet");
} else {
SnapshotLoader loader(engine, env, move_dir_req.job_id, move_dir_req.tablet_id);
+ SCOPED_ATTACH_TASK(loader.resource_ctx());
status = loader.move(move_dir_req.src, tablet, true);
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org