diff --git a/pkg/kv/kvserver/liveness/liveness.go b/pkg/kv/kvserver/liveness/liveness.go index 416053b93ecc..12a2951ff434 100644 --- a/pkg/kv/kvserver/liveness/liveness.go +++ b/pkg/kv/kvserver/liveness/liveness.go @@ -1408,7 +1408,7 @@ func (nl *NodeLiveness) updateLivenessAttempt( nl.mu.RLock() cb := nl.mu.onSelfLive nl.mu.RUnlock() - if cb != nil { + if nl.gossip.NodeID.Get() == update.newLiveness.NodeID && cb != nil { cb(ctx) } return Record{Liveness: update.newLiveness, raw: v.TagAndDataBytes()}, nil