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 2023/06/26 04:56:54 UTC
[doris] branch master updated: [fix](regression) fix p1 test_backup_restore fail caused by http download 401 invalid token error #21107
This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 66005570c9 [fix](regression) fix p1 test_backup_restore fail caused by http download 401 invalid token error #21107
66005570c9 is described below
commit 66005570c950dd0f4d5ec833d0a6e4f917b84a61
Author: ZhangYu0123 <67...@users.noreply.github.com>
AuthorDate: Mon Jun 26 12:56:46 2023 +0800
[fix](regression) fix p1 test_backup_restore fail caused by http download 401 invalid token error #21107
---
be/src/agent/task_worker_pool.cpp | 9 +++++----
regression-test/pipeline/p1/conf/fe.conf | 2 ++
2 files changed, 7 insertions(+), 4 deletions(-)
diff --git a/be/src/agent/task_worker_pool.cpp b/be/src/agent/task_worker_pool.cpp
index 463845d2c7..bfddfbff97 100644
--- a/be/src/agent/task_worker_pool.cpp
+++ b/be/src/agent/task_worker_pool.cpp
@@ -766,16 +766,17 @@ void TaskWorkerPool::_download_worker_thread_callback() {
}
LOG(INFO) << "get download task. signature=" << agent_task_req.signature
<< ", job_id=" << download_request.job_id
- << "task detail: " << apache::thrift::ThriftDebugString(download_request);
+ << ", task detail: " << apache::thrift::ThriftDebugString(download_request);
// TODO: download
std::vector<int64_t> downloaded_tablet_ids;
auto status = Status::OK();
if (download_request.__isset.remote_tablet_snapshots) {
- SnapshotLoader loader(_env, download_request.job_id, agent_task_req.signature);
- loader.remote_http_download(download_request.remote_tablet_snapshots,
- &downloaded_tablet_ids);
+ std::unique_ptr<SnapshotLoader> loader = std::make_unique<SnapshotLoader>(
+ _env, download_request.job_id, agent_task_req.signature);
+ status = loader->remote_http_download(download_request.remote_tablet_snapshots,
+ &downloaded_tablet_ids);
} else {
std::unique_ptr<SnapshotLoader> loader = std::make_unique<SnapshotLoader>(
_env, download_request.job_id, agent_task_req.signature,
diff --git a/regression-test/pipeline/p1/conf/fe.conf b/regression-test/pipeline/p1/conf/fe.conf
index 51c6cb2d2a..adc042357c 100644
--- a/regression-test/pipeline/p1/conf/fe.conf
+++ b/regression-test/pipeline/p1/conf/fe.conf
@@ -85,3 +85,5 @@ auto_check_statistics_in_sec=60
dynamic_partition_check_interval_seconds=3
enable_feature_binlog=true
+
+auth_token = 5ff161c3-2c08-4079-b108-26c8850b6598
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org