From f0d12aa68d569fdcad60566e39488f8a73be4d29 Mon Sep 17 00:00:00 2001 From: wei liu Date: Wed, 10 Jul 2024 09:50:38 +0800 Subject: [PATCH] fix: RootCoord panic during check health (#34542) issue: #34540 pr: #34541 Signed-off-by: Wei Liu --- internal/rootcoord/util.go | 12 +++++++----- 1 file changed, 7 insertions(+), 5 deletions(-) diff --git a/internal/rootcoord/util.go b/internal/rootcoord/util.go index 89b3ad5ae0..51d7bcc0f6 100644 --- a/internal/rootcoord/util.go +++ b/internal/rootcoord/util.go @@ -308,12 +308,14 @@ func CheckTimeTickLagExceeded(ctx context.Context, queryCoord types.QueryCoordCl for _, dataNodeMetric := range dataCoordTopology.Cluster.ConnectedDataNodes { dm := dataNodeMetric.QuotaMetrics - if dm.Fgm.NumFlowGraph > 0 && dm.Fgm.MinFlowGraphChannel != "" { - minTt, _ := tsoutil.ParseTS(dm.Fgm.MinFlowGraphTt) - delay := now.Sub(minTt) + if dm != nil { + if dm.Fgm.NumFlowGraph > 0 && dm.Fgm.MinFlowGraphChannel != "" { + minTt, _ := tsoutil.ParseTS(dm.Fgm.MinFlowGraphTt) + delay := now.Sub(minTt) - if delay.Milliseconds() >= maxDelay.Milliseconds() { - dataNodeTTDelay.Insert(dm.Fgm.MinFlowGraphChannel, delay) + if delay.Milliseconds() >= maxDelay.Milliseconds() { + dataNodeTTDelay.Insert(dm.Fgm.MinFlowGraphChannel, delay) + } } } }