Skip to content

Commit da93e13

Browse files
committed
chore(window): revert warn log to debug
Signed-off-by: Jiyong Huang <[email protected]>
1 parent b2497f2 commit da93e13

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

internal/topo/node/window_op.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -569,7 +569,7 @@ func (o *WindowOperator) handleInputs(ctx api.StreamContext, inputs []*xsql.Tupl
569569
content := make([]xsql.Row, 0, len(inputs))
570570
// Sync table
571571
left := right.Add(-length).Add(-delta)
572-
log.Warnf("triggerTime: %d, length: %d, delta: %d, leftmost: %d", right.UnixMilli(), length, delta, left.UnixMilli())
572+
log.Debugf("triggerTime: %d, length: %d, delta: %d, leftmost: %d", right.UnixMilli(), length, delta, left.UnixMilli())
573573
nextleft := -1
574574
// Assume the inputs are sorted by timestamp
575575
for i, tuple := range inputs {
@@ -610,7 +610,7 @@ func (o *WindowOperator) handleInputs(ctx api.StreamContext, inputs []*xsql.Tupl
610610
func (o *WindowOperator) gcInputs(inputs []*xsql.Tuple, triggerTime time.Time, ctx api.StreamContext) []*xsql.Tuple {
611611
var discard []*xsql.Tuple
612612
inputs, discard, _ = o.handleInputs(ctx, inputs, triggerTime)
613-
ctx.GetLogger().Warnf("after scan %v", inputs)
613+
ctx.GetLogger().Debugf("after scan %v", inputs)
614614
o.handleTraceDiscardTuple(ctx, discard)
615615
return inputs
616616
}

0 commit comments

Comments
 (0)