fix catchupped metric

This commit is contained in:
rasmus 2022-11-06 16:35:49 +02:00
parent 639cb6addd
commit 1744b94cef

View File

@ -124,7 +124,7 @@ func (s *submitter) shipFileRoutine(ctx context.Context, name string, sendQueue
}
if !catchUpped {
catchUpped = line.EndOffset > startSize
catchUpped = line.EndOffset >= startSize
if catchUpped {
promCatchupDone.WithLabelValues(baseName).Set(1)