diff --git a/src/rpc_client/src/meta_client.rs b/src/rpc_client/src/meta_client.rs index 5337613c4c89c..1b68a26bf6050 100644 --- a/src/rpc_client/src/meta_client.rs +++ b/src/rpc_client/src/meta_client.rs @@ -929,7 +929,7 @@ impl GrpcMetaClient { addr: &str, force_refresh_receiver: Receiver>>, ) -> Result<()> { - tracing::info!("using {} as initial leader", addr); + tracing::info!("using {} as initial leader and members", addr); let core_ref = self.core.clone(); let current_leader = addr.to_string(); let mut members = HashMap::new(); @@ -972,7 +972,7 @@ impl GrpcMetaClient { let members_resp = match client.to_owned().members(MembersRequest {}).await { Ok(resp) => resp.into_inner(), Err(e) => { - tracing::debug!("failed to fetch members from {}, {}", addr, e); + tracing::warn!("failed to fetch members from {}, {}", addr, e); continue; } }; @@ -1012,7 +1012,7 @@ impl GrpcMetaClient { let leader_resp = match client.to_owned().leader(LeaderRequest {}).await { Ok(resp) => resp.into_inner(), Err(e) => { - tracing::debug!("failed to fetch leader from {}, {}", addr, e); + tracing::warn!("failed to fetch leader from {}, {}", addr, e); continue; } }; @@ -1225,6 +1225,7 @@ impl GrpcMetaClient { code, Code::Unknown | Code::Unimplemented | Code::Unavailable ) { + tracing::info!("matching tonic code {}", code); let (result_sender, result_receiver) = oneshot::channel(); if self.force_refresh_sender.try_send(result_sender).is_ok() { if let Ok(Err(e)) = result_receiver.await {