This is an automated email from the ASF dual-hosted git repository.

kxiao pushed a commit to branch branch-2.0
in repository https://gitbox.apache.org/repos/asf/doris.git

commit 741c63df2bc42bb43c504f578df0b25d0e52d303
Author: zhangdong <493738...@qq.com>
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 cc75cc1713..63aa5d47ff 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: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org

Reply via email to