@@ -97,7 +97,7 @@ func (pl *DefaultPodTopologySpread) Score(ctx context.Context, state *framework.
97
97
}
98
98
99
99
// NormalizeScore invoked after scoring all nodes.
100
- // For this plugin, it calculates the source of each node
100
+ // For this plugin, it calculates the score of each node
101
101
// based on the number of existing matching pods on the node
102
102
// where zone information is included on the nodes, it favors nodes
103
103
// in zones with fewer existing matching pods.
@@ -116,7 +116,7 @@ func (pl *DefaultPodTopologySpread) NormalizeScore(ctx context.Context, state *f
116
116
}
117
117
nodeInfo , err := pl .handle .SnapshotSharedLister ().NodeInfos ().Get (scores [i ].Name )
118
118
if err != nil {
119
- return framework .NewStatus (framework .Error , err . Error ( ))
119
+ return framework .NewStatus (framework .Error , fmt . Sprintf ( "getting node %q from Snapshot: %v" , scores [ i ]. Name , err ))
120
120
}
121
121
zoneID := utilnode .GetZoneKey (nodeInfo .Node ())
122
122
if zoneID == "" {
@@ -147,7 +147,7 @@ func (pl *DefaultPodTopologySpread) NormalizeScore(ctx context.Context, state *f
147
147
if haveZones {
148
148
nodeInfo , err := pl .handle .SnapshotSharedLister ().NodeInfos ().Get (scores [i ].Name )
149
149
if err != nil {
150
- return framework .NewStatus (framework .Error , err . Error ( ))
150
+ return framework .NewStatus (framework .Error , fmt . Sprintf ( "getting node %q from Snapshot: %v" , scores [ i ]. Name , err ))
151
151
}
152
152
153
153
zoneID := utilnode .GetZoneKey (nodeInfo .Node ())
0 commit comments