fix: invalid rate limit for time tick delay

Signed-off-by: jaime <[email protected]>
milvus-io · Dec 4, 2024 · 8b7f25e · 8b7f25e
1 parent febed0a
commit 8b7f25e
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,