Skip to content

Commit e8a94ef

Browse files
fix: set delete request batch to empty when we load to fail requests (#17810)
Signed-off-by: Sandeep Sukhani <[email protected]>
1 parent f6a0926 commit e8a94ef

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

pkg/compactor/deletion/delete_requests_manager.go

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -67,6 +67,7 @@ func NewDeleteRequestsManager(workingDir string, store DeleteRequestsStore, dele
6767
batchSize: batchSize,
6868
limits: limits,
6969
processedSeries: map[string]struct{}{},
70+
currentBatch: newDeleteRequestBatch(metrics),
7071
}
7172

7273
var err error
@@ -333,7 +334,7 @@ func (d *DeleteRequestsManager) MarkPhaseStarted() {
333334
status := statusSuccess
334335
if batch, err := d.loadDeleteRequestsToProcess(DeleteRequestsAll); err != nil {
335336
status = statusFail
336-
d.currentBatch = nil
337+
d.currentBatch = newDeleteRequestBatch(d.metrics)
337338
level.Error(util_log.Logger).Log("msg", "failed to load delete requests to process", "err", err)
338339
} else {
339340
d.currentBatch = batch

0 commit comments

Comments
 (0)