From 8b7f25e31b6450b50aabcfe0ec12fce37b612b01 Mon Sep 17 00:00:00 2001 From: jaime Date: Wed, 4 Dec 2024 20:42:07 +0800 Subject: [PATCH] fix: invalid rate limit for time tick delay Signed-off-by: jaime --- internal/datanode/flow_graph_write_node.go | 1 + 1 file changed, 1 insertion(+) diff --git a/internal/datanode/flow_graph_write_node.go b/internal/datanode/flow_graph_write_node.go index 2425a9591bf50..16e973ef4454b 100644 --- a/internal/datanode/flow_graph_write_node.go +++ b/internal/datanode/flow_graph_write_node.go @@ -98,6 +98,7 @@ func (wNode *writeNode) Operate(in []Msg) []Msg { }) wNode.updater.update(wNode.channelName, end.GetTimestamp(), stats) + rateCol.updateFlowGraphTt(wNode.channelName, end.GetTimestamp()) res := flowGraphMsg{ timeRange: fgMsg.timeRange,