diff --git a/src/meta-client/src/client.rs b/src/meta-client/src/client.rs index fed97c5681..ddb169ebc5 100644 --- a/src/meta-client/src/client.rs +++ b/src/meta-client/src/client.rs @@ -468,28 +468,24 @@ impl MetaClient { Ok(res) } - #[inline] pub fn heartbeat_client(&self) -> Result { self.heartbeat.clone().context(NotStartedSnafu { name: "heartbeat_client", }) } - #[inline] pub fn store_client(&self) -> Result { self.store.clone().context(NotStartedSnafu { name: "store_client", }) } - #[inline] pub fn lock_client(&self) -> Result { self.lock.clone().context(NotStartedSnafu { name: "lock_client", }) } - #[inline] pub fn procedure_client(&self) -> Result { self.procedure.clone().context(NotStartedSnafu { name: "procedure_client", @@ -502,12 +498,10 @@ impl MetaClient { }) } - #[inline] pub fn channel_config(&self) -> &ChannelConfig { self.channel_manager.config() } - #[inline] pub fn id(&self) -> Id { self.id } diff --git a/src/meta-srv/src/election/etcd.rs b/src/meta-srv/src/election/etcd.rs index 695808a787..0b615c78e6 100644 --- a/src/meta-srv/src/election/etcd.rs +++ b/src/meta-srv/src/election/etcd.rs @@ -166,7 +166,7 @@ impl Election for EtcdElection { if let Some(res) = receiver.message().await.context(error::EtcdFailedSnafu)? { if res.ttl() <= 0 { - // Failed to keep alive, just break the loop. + warn!("Candidate lease expired, key: {}", self.candidate_key()); break; } }