Skip to content

Commit

Permalink
[fix](regression) fix p1 test_backup_restore fail caused by http down…
Browse files Browse the repository at this point in the history
…load 401 invalid token error apache#21107
  • Loading branch information
ZhangYu0123 authored Jun 26, 2023
1 parent 1dec592 commit 6600557
Show file tree
Hide file tree
Showing 2 changed files with 7 additions and 4 deletions.
9 changes: 5 additions & 4 deletions be/src/agent/task_worker_pool.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -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,
Expand Down
2 changes: 2 additions & 0 deletions regression-test/pipeline/p1/conf/fe.conf
Original file line number Diff line number Diff line change
Expand Up @@ -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

0 comments on commit 6600557

Please sign in to comment.