@@ -238,17 +238,16 @@ func (s *Scheduler) RegisterFromNodeAnnotations() {
238238 }
239239 s .addNode (val .Name , nodeInfo )
240240 if s .nodes [val .Name ] != nil && len (nodeInfo .Devices ) > 0 {
241- action := "updated"
242- if ! printedLog [val .Name ] {
243- action = "added"
241+ if printedLog [val .Name ] {
242+ klog .InfoS ("Node device updated" , "nodeName" , val .Name , "deviceVendor" , devhandsk , "nodeInfo" , nodeInfo , "totalDevices" , s .nodes [val .Name ].Devices )
243+ } else {
244+ klog .InfoS ("Node device added" , "nodeName" , val .Name , "deviceVendor" , devhandsk , "nodeInfo" , nodeInfo , "totalDevices" , s .nodes [val .Name ].Devices )
244245 printedLog [val .Name ] = true
245246 }
246-
247247 klog .InfoS ("Node device inventory changed" ,
248248 "nodeName" , val .Name ,
249249 "deviceVendor" , devhandsk ,
250- "deviceCount" , len (nodeInfo .Devices ),
251- "action" , action )
250+ "deviceCount" , len (nodeInfo .Devices ))
252251 }
253252 }
254253 }
@@ -368,8 +367,6 @@ func (s *Scheduler) getNodesUsage(nodes *[]string, task *corev1.Pod) (*map[strin
368367 for _ , nodeID := range * nodes {
369368 node , err := s .GetNode (nodeID )
370369 if err != nil {
371- // 注意:使用V(3)而不是InfoS,这样只有在debug模式下才输出
372- // 这些节点可能是正常的非GPU节点,不应该污染正常日志
373370 klog .V (3 ).InfoS ("Node unregistered or no GPU devices found" ,
374371 "nodeName" , nodeID ,
375372 "error" , err )
0 commit comments