diff --git a/pkg/scheduler/internal/cache/debugger/dumper.go b/pkg/scheduler/internal/cache/debugger/dumper.go index 497d4b1b71f..6291b1f0629 100644 --- a/pkg/scheduler/internal/cache/debugger/dumper.go +++ b/pkg/scheduler/internal/cache/debugger/dumper.go @@ -46,7 +46,7 @@ func (d *CacheDumper) dumpNodes() { snapshot := d.cache.Snapshot() klog.Info("Dump of cached NodeInfo") for _, nodeInfo := range snapshot.Nodes { - klog.Info(printNodeInfo(nodeInfo)) + klog.Info(d.printNodeInfo(nodeInfo)) } } @@ -61,14 +61,22 @@ func (d *CacheDumper) dumpSchedulingQueue() { } // printNodeInfo writes parts of NodeInfo to a string. -func printNodeInfo(n *schedulernodeinfo.NodeInfo) string { +func (d *CacheDumper) printNodeInfo(n *schedulernodeinfo.NodeInfo) string { var nodeData strings.Builder - nodeData.WriteString(fmt.Sprintf("\nNode name: %+v\nRequested Resources: %+v\nAllocatable Resources:%+v\nNumber of Pods: %v\nPods:\n", + nodeData.WriteString(fmt.Sprintf("\nNode name: %+v\nRequested Resources: %+v\nAllocatable Resources:%+v\nScheduled Pods(number: %v):\n", n.Node().Name, n.RequestedResource(), n.AllocatableResource(), len(n.Pods()))) // Dumping Pod Info for _, p := range n.Pods() { nodeData.WriteString(printPod(p)) } + // Dumping nominated pods info on the node + nominatedPods := d.podQueue.NominatedPodsForNode(n.Node().Name) + if len(nominatedPods) != 0 { + nodeData.WriteString(fmt.Sprintf("Nominated Pods(number: %v):\n", len(nominatedPods))) + for _, p := range nominatedPods { + nodeData.WriteString(printPod(p)) + } + } return nodeData.String() }