File tree Expand file tree Collapse file tree 1 file changed +1
-6
lines changed
Expand file tree Collapse file tree 1 file changed +1
-6
lines changed Original file line number Diff line number Diff line change @@ -143,12 +143,7 @@ func (ch *ChunkDataPacks) Store(cs []*flow.ChunkDataPack) (
143143 storeChunkDataPacksFunc := func (lctx lockctx.Proof , protocolDBBatch storage.ReaderBatchWriter ) error {
144144 protocolDBBatch .AddCallback (func (err error ) {
145145 if err != nil {
146- log .Warn ().Err (err ).Msgf ("batch operation failed, rolling back stored chunk data packs for chunks: %v" , cs )
147- // Rollback the stored chunk data packs if the batch operation fails
148- err := ch .stored .Remove (chunkDataPackIDs ) // rollback stored chunk data packs on failure
149- if err != nil {
150- log .Fatal ().Err (err ).Msgf ("cannot rollback stored chunk data packs" ) // log the error, but do not override the original error
151- }
146+ log .Warn ().Err (err ).Msgf ("indexing chunkID -> chunkDataPackID mapping failed, chunkDataPackIDs: %v" , chunkDataPackIDs )
152147 }
153148 })
154149
You can’t perform that action at this time.
0 commit comments