This is an automated email from the ASF dual-hosted git repository. dataroaring pushed a commit to branch branch-3.0 in repository https://gitbox.apache.org/repos/asf/doris.git
commit 7ca141bd9970f06bf11156d4e623b12fa4bf4578 Author: Yongqiang YANG <[email protected]> AuthorDate: Thu May 16 16:40:49 2024 +0800 [fix](thrift rpc) skip handle retry in asan mode (#34813) --- be/src/util/thrift_rpc_helper.cpp | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/be/src/util/thrift_rpc_helper.cpp b/be/src/util/thrift_rpc_helper.cpp index 25d78129387..5d11cc6abb1 100644 --- a/be/src/util/thrift_rpc_helper.cpp +++ b/be/src/util/thrift_rpc_helper.cpp @@ -74,6 +74,10 @@ Status ThriftRpcHelper::rpc(const std::string& ip, const int32_t port, callback(client); } catch (apache::thrift::transport::TTransportException& e) { std::cerr << "thrift error, reason=" << e.what(); +#ifdef ADDRESS_SANITIZER + return Status::RpcError("failed to call frontend service, FE address={}:{}, reason: {}", + ip, port, e.what()); +#else LOG(WARNING) << "retrying call frontend service after " << config::thrift_client_retry_interval_ms << " ms, address=" << address << ", reason=" << e.what(); @@ -86,6 +90,7 @@ Status ThriftRpcHelper::rpc(const std::string& ip, const int32_t port, return status; } callback(client); +#endif } } catch (apache::thrift::TException& e) { LOG(WARNING) << "call frontend service failed, address=" << address --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
