This is an automated email from the ASF dual-hosted git repository. zhangstar333 pushed a commit to branch doris_master_new in repository https://gitbox.apache.org/repos/asf/doris.git
commit 919fbd599fa26fee22c0163acb6d89c7b7c732cb Author: zhangstar333 <[email protected]> AuthorDate: Sat May 23 23:12:03 2026 +0800 fe with be cache uuid --- be/src/exec/sink/writer/vtablet_writer.cpp | 4 ++-- be/src/runtime/fragment_mgr.cpp | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/be/src/exec/sink/writer/vtablet_writer.cpp b/be/src/exec/sink/writer/vtablet_writer.cpp index 9f86cd707d2..5c19d28e85f 100644 --- a/be/src/exec/sink/writer/vtablet_writer.cpp +++ b/be/src/exec/sink/writer/vtablet_writer.cpp @@ -1213,8 +1213,8 @@ void VNodeChannel::try_send_pending_block(RuntimeState* state) { //format an ipv6 address std::string brpc_url = get_brpc_http_url(host, _node_info.brpc_port); std::shared_ptr<PBackendService_Stub> _brpc_http_stub = - _state->exec_env()->brpc_internal_client_cache()->get_new_client_no_cache(brpc_url, - "http"); + _state->exec_env()->brpc_internal_client_cache()->get_new_client_no_cache( + brpc_url, "http", "", "", _node_info.host); if (_brpc_http_stub == nullptr) { cancel(fmt::format("{}, failed to open brpc http client to {}", channel_info(), brpc_url)); diff --git a/be/src/runtime/fragment_mgr.cpp b/be/src/runtime/fragment_mgr.cpp index 76bbf3a2e65..e56fe738fa0 100644 --- a/be/src/runtime/fragment_mgr.cpp +++ b/be/src/runtime/fragment_mgr.cpp @@ -907,7 +907,7 @@ void FragmentMgr::_collect_invalid_queries( auto itr = running_fes.find(q_ctx->coord_addr); if (itr != running_fes.end()) { - if (fe_process_uuid == itr->second.info.process_uuid || + if (fe_process_uuid >= itr->second.info.process_uuid || itr->second.info.process_uuid == 0) { continue; } else { --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
