diff --git a/pkg/storage/replicate_queue.go b/pkg/storage/replicate_queue.go index 21a01ba70cb8..be08c229fd0e 100644 --- a/pkg/storage/replicate_queue.go +++ b/pkg/storage/replicate_queue.go @@ -338,7 +338,7 @@ func (rq *replicateQueue) processOneChange( case AllocatorRemove: log.VEventf(ctx, 1, "removing a replica") lastReplAdded, lastAddedTime := repl.LastReplicaAdded() - if timeutil.Since(lastAddedTime) < newReplicaGracePeriod { + if timeutil.Since(lastAddedTime) > newReplicaGracePeriod { lastReplAdded = 0 } candidates := filterUnremovableReplicas(repl.RaftStatus(), desc.Replicas, lastReplAdded)