diff --git a/be/src/service/internal_service.cpp b/be/src/service/internal_service.cpp index 6f7aaf5229492d..04abf2b09ce01d 100644 --- a/be/src/service/internal_service.cpp +++ b/be/src/service/internal_service.cpp @@ -1918,11 +1918,6 @@ void PInternalServiceImpl::_response_pull_slave_rowset(const std::string& remote pull_rowset_callback->join(); if (pull_rowset_callback->cntl_->Failed()) { - if (!ExecEnv::GetInstance()->brpc_internal_client_cache()->available(stub, remote_host, - brpc_port)) { - ExecEnv::GetInstance()->brpc_internal_client_cache()->erase( - closure->cntl_->remote_side()); - } LOG(WARNING) << "failed to response result of slave replica to master replica, error=" << berror(pull_rowset_callback->cntl_->ErrorCode()) << ", error_text=" << pull_rowset_callback->cntl_->ErrorText()