GiteaTest2015/streamsql
1
0
Fork 1
mirror of https://gitee.com/rulego/streamsql.git synced 2026-04-12 23:37:06 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix:数据竞争问题

Browse Source
This commit is contained in:
rulego-team
2025-06-13 21:10:04 +08:00
parent 6b48b1d83b
commit 07488300f5
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
window/counting_window.go
+2 -2
View File
@@ -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 {