diff --git a/clientv3/snapshot/v3_snapshot.go b/clientv3/snapshot/v3_snapshot.go index c512c3986..cda493aad 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)