From 01a31749ec74485ced12d5d4d63156b79881c921 Mon Sep 17 00:00:00 2001 From: Kaijie Chen Date: Thu, 29 Aug 2024 10:23:55 +0800 Subject: [PATCH] use get_client(host, port) for dnscache --- be/src/vec/sink/load_stream_stub.cpp | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/be/src/vec/sink/load_stream_stub.cpp b/be/src/vec/sink/load_stream_stub.cpp index acfe5af579f07c3..34a6d459c365836 100644 --- a/be/src/vec/sink/load_stream_stub.cpp +++ b/be/src/vec/sink/load_stream_stub.cpp @@ -152,7 +152,6 @@ Status LoadStreamStub::open(BrpcClientCache* client_cache, return _init_st; } _dst_id = node_info.id; - std::string host_port = get_host_port(node_info.host, node_info.brpc_port); brpc::StreamOptions opt; opt.max_buf_size = config::load_stream_max_buf_size; opt.idle_timeout_ms = idle_timeout_ms; @@ -185,7 +184,7 @@ Status LoadStreamStub::open(BrpcClientCache* client_cache, } POpenLoadStreamResponse response; // set connection_group "streaming" to distinguish with non-streaming connections - const auto& stub = client_cache->get_client(host_port); + const auto& stub = client_cache->get_client(node_info.host, node_info.brpc_port); if (stub == nullptr) { return Status::InternalError("failed to init brpc client to {}", host_port); } @@ -203,7 +202,8 @@ Status LoadStreamStub::open(BrpcClientCache* client_cache, cntl.ErrorText()); return _init_st; } - LOG(INFO) << "open load stream to " << host_port << ", " << *this; + LOG(INFO) << "open load stream to host=" << node_info.host << ", port=" << node_info.brpc_port + << ", " << *this; _is_init.store(true); return Status::OK(); }