Skip to content

Commit

Permalink
Exit if we get rescinded or slave lost. We may want to make this more…
Browse files Browse the repository at this point in the history
… resilient but need this as bandaid otherwise can take hang and take all resources from mesos.
  • Loading branch information
hekaldama committed May 25, 2016
1 parent d1a49d6 commit 2db49e9
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions main.go
Expand Up @@ -65,13 +65,13 @@ func (sched *MesosRunonceScheduler) Disconnected(sched.SchedulerDriver) {
log.Exitf("disconnected from master, aborting")
}
func (sched *MesosRunonceScheduler) OfferRescinded(_ sched.SchedulerDriver, oid *mesos.OfferID) {
log.Errorf("offer rescinded: %v", oid)
log.Exitf("offer rescinded: %v", oid)
}
func (sched *MesosRunonceScheduler) FrameworkMessage(_ sched.SchedulerDriver, eid *mesos.ExecutorID, sid *mesos.SlaveID, msg string) {
log.Errorf("framework message from executor %q slave %q: %q", eid, sid, msg)
}
func (sched *MesosRunonceScheduler) SlaveLost(_ sched.SchedulerDriver, sid *mesos.SlaveID) {
log.Errorf("slave lost: %v", sid)
log.Exitf("slave lost: %v", sid)
}
func (sched *MesosRunonceScheduler) ExecutorLost(_ sched.SchedulerDriver, eid *mesos.ExecutorID, sid *mesos.SlaveID, code int) {
log.Errorf("executor %q lost on slave %q code %d", eid, sid, code)
Expand Down

0 comments on commit 2db49e9

Please sign in to comment.