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)