driver.acceptOffers(offerIds, operations, filters);
}
}
@Override
public void slaveLost(SchedulerDriver driver, Protos.SlaveID slaveId) {
<BUG>System.out.println("Executor " + slaveId.getValue() + " was lost.");
}</BUG>
@Override
public void statusUpdate(SchedulerDriver driver, Protos.TaskStatus status) {
String taskId = status.getTaskId().getValue();

driver.acceptOffers(offerIds, operations, filters);
}
}
@Override
public void slaveLost(SchedulerDriver driver, Protos.SlaveID slaveId) {
LOG.info(String.format("Executor %s was lost", slaveId.getValue()));
}
@Override
public void statusUpdate(SchedulerDriver driver, Protos.TaskStatus status) {
String taskId = status.getTaskId().getValue();
