diff --git a/pkg/kv/kvserver/raft_transport.go b/pkg/kv/kvserver/raft_transport.go index d6e0c1c505cf..3090305ce134 100644 --- a/pkg/kv/kvserver/raft_transport.go +++ b/pkg/kv/kvserver/raft_transport.go @@ -916,7 +916,6 @@ func (t *RaftTransport) startProcessNewQueue( } }() defer cleanup(q) - defer t.queues[class].Delete(int64(toNodeID)) defer func() { t.kvflowControl.mu.Lock() t.queues[class].Delete(int64(toNodeID))