diff --git a/src/datanode/src/heartbeat.rs b/src/datanode/src/heartbeat.rs index 313506a86347..60a6fd8a3b77 100644 --- a/src/datanode/src/heartbeat.rs +++ b/src/datanode/src/heartbeat.rs @@ -246,6 +246,8 @@ impl HeartbeatTask { Ok(new_tx) => { info!("Reconnected to metasrv"); tx = new_tx; + // Triggers to send heartbeat immediately. + sleep.as_mut().reset(Instant::now()); } Err(e) => { error!(e;"Failed to reconnect to metasrv!");