File tree Expand file tree Collapse file tree 1 file changed +3
-6
lines changed
Expand file tree Collapse file tree 1 file changed +3
-6
lines changed Original file line number Diff line number Diff line change @@ -1673,12 +1673,9 @@ func NewStore(
16731673 // it can clean it up. If this fails it's not a correctness issue since the
16741674 // storage is also cleared before receiving a snapshot.
16751675 //
1676- // TODO(sep-raft-log): need a snapshot storage per engine since we'll need to split
1677- // the SSTs. Or probably we don't need snapshots on the raft SST at all - the reason
1678- // we use them now is because we want snapshot apply to be completely atomic but that
1679- // is out the window with two engines, so we may as well break the atomicity in the
1680- // common case and do something more effective.
1681- s .sstSnapshotStorage = snaprecv .NewSSTSnapshotStorage (s .TODOEngine (), s .limiters .BulkIOWriteRate )
1676+ // NB: we don't need the snapshot storage in the raft engine. With separated
1677+ // storage, the log engine part of snapshot ingestion is written as a batch.
1678+ s .sstSnapshotStorage = snaprecv .NewSSTSnapshotStorage (s .StateEngine (), s .limiters .BulkIOWriteRate )
16821679 if err := s .sstSnapshotStorage .Clear (); err != nil {
16831680 log .KvDistribution .Warningf (ctx , "failed to clear snapshot storage: %v" , err )
16841681 }
You can’t perform that action at this time.
0 commit comments