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 32dd088d30 [fix](inverted)fix inverted index report be hostname error
#23872
32dd088d30 is described below
commit 32dd088d30cc887893c58c3c36376e47f3bd487e
Author: zhangdong <[email protected]>
AuthorDate: Tue Sep 5 10:52:23 2023 +0800
[fix](inverted)fix inverted index report be hostname error #23872
when inverted index report task status to fe,not put the correct host
delete unused _backend
---
be/src/agent/task_worker_pool.cpp | 6 +-----
be/src/agent/task_worker_pool.h | 1 -
2 files changed, 1 insertion(+), 6 deletions(-)
diff --git a/be/src/agent/task_worker_pool.cpp
b/be/src/agent/task_worker_pool.cpp
index 625fa7abe7..637c92af5a 100644
--- a/be/src/agent/task_worker_pool.cpp
+++ b/be/src/agent/task_worker_pool.cpp
@@ -107,10 +107,6 @@ TaskWorkerPool::TaskWorkerPool(const TaskWorkerType
task_worker_type, ExecEnv* e
_thread_model(thread_model),
_is_doing_work(false),
_task_worker_type(task_worker_type) {
- _backend.__set_host(BackendOptions::get_localhost());
- _backend.__set_be_port(config::be_port);
- _backend.__set_http_port(config::webserver_port);
-
string task_worker_type_name = TYPE_STRING(task_worker_type);
_name = strings::Substitute("TaskWorkerPool.$0", task_worker_type_name);
@@ -363,7 +359,7 @@ void
TaskWorkerPool::_alter_inverted_index_worker_thread_callback() {
// Return result to fe
TFinishTaskRequest finish_task_request;
- finish_task_request.__set_backend(_backend);
+ finish_task_request.__set_backend(BackendOptions::get_local_backend());
finish_task_request.__set_task_type(agent_task_req.task_type);
finish_task_request.__set_signature(agent_task_req.signature);
std::vector<TTabletInfo> finish_tablet_infos;
diff --git a/be/src/agent/task_worker_pool.h b/be/src/agent/task_worker_pool.h
index 83fcc1ff1d..50c8842166 100644
--- a/be/src/agent/task_worker_pool.h
+++ b/be/src/agent/task_worker_pool.h
@@ -226,7 +226,6 @@ protected:
// Reference to the ExecEnv::_master_info
const TMasterInfo& _master_info;
- TBackend _backend;
std::unique_ptr<AgentUtils> _agent_utils;
ExecEnv* _env;
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
