diff --git a/cluster/mesos/cluster.go b/cluster/mesos/cluster.go index 201bbe67b6..d268117d93 100644 --- a/cluster/mesos/cluster.go +++ b/cluster/mesos/cluster.go @@ -444,6 +444,7 @@ func (c *Cluster) removeOffer(offer *mesosproto.Offer) bool { found := s.removeOffer(offer.Id.GetValue()) if s.empty() { // Disconnect from engine + s.engine.Disconnect() delete(c.agents, offer.SlaveId.GetValue()) } return found