From 07488300f5ffec08483a5510a161b0ecd5c059fd Mon Sep 17 00:00:00 2001 From: rulego-team Date: Fri, 13 Jun 2025 21:10:04 +0800 Subject: [PATCH] =?UTF-8?q?fix:=E6=95=B0=E6=8D=AE=E7=AB=9E=E4=BA=89?= =?UTF-8?q?=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- window/counting_window.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/window/counting_window.go b/window/counting_window.go index 4ffa47c..3704177 100644 --- a/window/counting_window.go +++ b/window/counting_window.go @@ -121,8 +121,8 @@ func (cw *CountingWindow) Trigger() { func (cw *CountingWindow) Reset() { cw.mu.Lock() + defer cw.mu.Unlock() cw.count = 0 - cw.mu.Unlock() cw.dataBuffer = nil } @@ -140,7 +140,7 @@ func (cw *CountingWindow) createSlot(data []types.Row) *types.TimeSlot { return nil } else if len(data) < cw.threshold { start := timex.AlignTime(data[0].Timestamp, cw.config.TimeUnit, true) - end := timex.AlignTime(data[len(cw.dataBuffer)-1].Timestamp, cw.config.TimeUnit, false) + end := timex.AlignTime(data[len(data)-1].Timestamp, cw.config.TimeUnit, false) slot := types.NewTimeSlot(&start, &end) return slot } else {