diff --git a/contrib/mesos/pkg/scheduler/plugin.go b/contrib/mesos/pkg/scheduler/plugin.go index 3733033af86..a1bd3450434 100644 --- a/contrib/mesos/pkg/scheduler/plugin.go +++ b/contrib/mesos/pkg/scheduler/plugin.go @@ -313,11 +313,7 @@ func (k *kubeScheduler) doSchedule(task *podtask.T) (string, error) { if task.HasAcceptedOffer() { // verify that the offer is still on the table - offerId := task.GetOfferId() - if offer, ok := k.api.offers().Get(offerId); ok && !offer.HasExpired() { - // skip tasks that have already have assigned offers - offer = task.Offer - } else { + if offer, ok := k.api.offers().Get(task.GetOfferId()); !ok || offer.HasExpired() { task.Offer.Release() task.Reset() if err = k.api.tasks().Update(task); err != nil {