File tree 1 file changed +7
-1
lines changed
pkg/scheduler/plugins/proportion
1 file changed +7
-1
lines changed Original file line number Diff line number Diff line change @@ -181,7 +181,7 @@ func (pp *proportionPlugin) OnSessionOpen(ssn *framework.Session) {
181
181
}
182
182
allocated := allocations [job .Queue ]
183
183
if allocated .Less (reclaimee .Resreq ) {
184
- glog .Errorf ( "Failed to allocate resource for Task <%s/%s> in Queue <%s>, not enough resource." ,
184
+ glog .V ( 3 ). Infof ( "Failed to allocate resource for Task <%s/%s> in Queue <%s>, not enough resource." ,
185
185
reclaimee .Namespace , reclaimee .Name , job .Queue )
186
186
continue
187
187
}
@@ -213,6 +213,12 @@ func (pp *proportionPlugin) OnSessionOpen(ssn *framework.Session) {
213
213
queueID := job .Queue
214
214
attr := pp .queueOpts [queueID ]
215
215
queue := ssn .Queues [queueID ]
216
+
217
+ // If no capability is set, always enqueue the job.
218
+ if len (queue .Queue .Spec .Capability ) == 0 {
219
+ return true
220
+ }
221
+
216
222
pgResource := api .NewResource (* job .PodGroup .Spec .MinResources )
217
223
// The queue resource quota limit has not reached
218
224
if pgResource .Clone ().Add (attr .allocated ).LessEqual (api .NewResource (queue .Queue .Spec .Capability )) {
You can’t perform that action at this time.
0 commit comments