diff --git a/storage/metric/curator.go b/storage/metric/curator.go index 5f458f50f3..bb00f2dd3f 100644 --- a/storage/metric/curator.go +++ b/storage/metric/curator.go @@ -338,8 +338,7 @@ func (w *watermarkScanner) Operate(key, _ interface{}) (oErr *storage.OperatorEr ProcessorMessageRaw: w.processor.Signature(), ProcessorMessageTypeName: w.processor.Name(), IgnoreYoungerThan: w.ignoreYoungerThan, - }, - lastTime) + }, lastTime) if err != nil { // Under the assumption that the processors are idempotent, they can be // re-run; thusly, the commitment of the curation remark is no cause