fix(window): sliding delay time

Signed-off-by: Jiyong Huang <[email protected]>
lf-edge · Dec 5, 2024 · b0a7549 · b0a7549
1 parent 6a2d600
commit b0a7549
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/internal/topo/node/window_op.go b/internal/topo/node/window_op.go
@@ -345,7 +345,7 @@ func (o *WindowOperator) execProcessingWindow(ctx api.StreamContext, inputs []*x
 					if o.isMatchCondition(ctx, d) {
 						if o.window.Delay > 0 {
 							go func(ts time.Time) {
-								after := time.After(o.window.Delay * time.Millisecond)
+								after := time.After(o.window.Delay)
 								select {
 								case <-after:
 									delayCh <- ts