diff --git a/clientv3/snapshot/v3_snapshot.go b/clientv3/snapshot/v3_snapshot.go index c512c3986ed2..cda493aada2b 100644 --- a/clientv3/snapshot/v3_snapshot.go +++ b/clientv3/snapshot/v3_snapshot.go @@ -445,6 +445,7 @@ func (s *v3Manager) modifyLatestRevision(bumpAmount uint64) error { }() tx := be.BatchTx() + tx.Lock() defer tx.Unlock() latest, err := s.unsafeGetLatestRevision(tx)