Fixed a bug when flushing a range from the memory buffer (#455)

observIQ · Sep 29, 2021 · 3093caf · 3093caf
1 parent 134ff37
commit 3093caf
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/operator/buffer/memory.go b/operator/buffer/memory.go
@@ -195,7 +195,7 @@ func (mc *memoryClearer) MarkRangeAsFlushed(start, end uint) error {
 		delete(mc.buffer.inFlight, id)
 	}
 	mc.buffer.inFlightMux.Unlock()
-	mc.buffer.sem.Release(int64(end - start - 1))
+	mc.buffer.sem.Release(int64(end - start))
 	return nil
 }