diff --git a/be/src/util/thrift_rpc_helper.cpp b/be/src/util/thrift_rpc_helper.cpp index 4410a27ee4..7904fc0b7b 100644 --- a/be/src/util/thrift_rpc_helper.cpp +++ b/be/src/util/thrift_rpc_helper.cpp @@ -73,22 +73,38 @@ Status ThriftRpcHelper::rpc(const std::string& ip, const int32_t port, try { callback(client); } catch (apache::thrift::transport::TTransportException& e) { +#ifndef ADDRESS_SANITIZER LOG(WARNING) << "retrying call frontend service after " << config::thrift_client_retry_interval_ms << " ms, address=" << address << ", reason=" << e.what(); +#else + std::cerr << "retrying call frontend service after " + << config::thrift_client_retry_interval_ms << " ms, address=" << address + << ", reason=" << e.what() << std::endl; +#endif std::this_thread::sleep_for( std::chrono::milliseconds(config::thrift_client_retry_interval_ms)); status = client.reopen(timeout_ms); if (!status.ok()) { +#ifndef ADDRESS_SANITIZER LOG(WARNING) << "client reopen failed. address=" << address << ", status=" << status; +#else + std::cerr << "client reopen failed. address=" << address << ", status=" << status + << std::endl; +#endif return status; } callback(client); } } catch (apache::thrift::TException& e) { +#ifndef ADDRESS_SANITIZER LOG(WARNING) << "call frontend service failed, address=" << address << ", reason=" << e.what(); +#else + std::cerr << "call frontend service failed, address=" << address << ", reason=" << e.what() + << std::endl; +#endif std::this_thread::sleep_for( std::chrono::milliseconds(config::thrift_client_retry_interval_ms * 2)); // just reopen to disable this connection