From d6e537c91c64fb7a419fc234aee50906d411c5e4 Mon Sep 17 00:00:00 2001 From: yiwangdr <80064917+yiwangdr@users.noreply.github.com> Date: Tue, 7 May 2024 23:03:29 -0700 Subject: [PATCH] fix: allow datanode's server id to be updated (#31597) issue: #31516 background: the server id field in data node is redundant. session id already provides the source of truth. Signed-off-by: yiwangdr --- internal/datanode/data_node.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/datanode/data_node.go b/internal/datanode/data_node.go index 234c3ec9f9..7ee37c7cae 100644 --- a/internal/datanode/data_node.go +++ b/internal/datanode/data_node.go @@ -242,7 +242,7 @@ func (node *DataNode) Init() error { return } - serverID := node.session.ServerID + serverID := node.GetNodeID() log := log.Ctx(node.ctx).With(zap.String("role", typeutil.DataNodeRole), zap.Int64("nodeID", serverID)) node.broker = broker.NewCoordBroker(node.rootCoord, node.dataCoord, serverID)