fix: invalid rate limit for time tick delay (#38218)

issue: #38217 Signed-off-by: jaime <[email protected]>
milvus-io · Dec 5, 2024 · 67a004c · 67a004c
1 parent f888267
commit 67a004c
Showing 1 changed file with 1 addition and 0 deletions.
diff --git 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,