From f5f91a9ca4b6503cbfb04a8098f2eaca18b6e216 Mon Sep 17 00:00:00 2001 From: Oleg Zaytsev Date: Mon, 31 Mar 2025 08:06:27 +0000 Subject: [PATCH] defer a.unmarkCreatedSeriesAsPendingCommit() Signed-off-by: Oleg Zaytsev --- tsdb/head_append.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/tsdb/head_append.go b/tsdb/head_append.go index bb20593ca5..03800b2455 100644 --- a/tsdb/head_append.go +++ b/tsdb/head_append.go @@ -1964,6 +1964,7 @@ func (a *headAppender) Rollback() (err error) { defer a.head.metrics.activeAppenders.Dec() defer a.head.iso.closeAppend(a.appendID) defer a.head.putSeriesBuffer(a.sampleSeries) + defer a.unmarkCreatedSeriesAsPendingCommit() var series *memSeries for i := range a.samples { @@ -1980,7 +1981,6 @@ func (a *headAppender) Rollback() (err error) { series.pendingCommit = false series.Unlock() } - a.unmarkCreatedSeriesAsPendingCommit() a.head.putAppendBuffer(a.samples) a.head.putExemplarBuffer(a.exemplars) a.head.putHistogramBuffer(a.histograms)