Details
-
Improvement
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
None
Description
Update this to send TASK_DROPPED for partition-aware frameworks:
if (!connected) { VLOG(1) << "Ignoring accept offers message as master is disconnected"; // NOTE: Reply to the framework with TASK_LOST messages for each // task launch. See details from notes in launchTasks. foreach (const Offer::Operation& operation, operations) { if (operation.type() != Offer::Operation::LAUNCH) { continue; } foreach (const TaskInfo& task, operation.launch().task_infos()) { StatusUpdate update = protobuf::createStatusUpdate( framework.id(), None(), task.task_id(), TASK_LOST, TaskStatus::SOURCE_MASTER, None(), "Master disconnected", TaskStatus::REASON_MASTER_DISCONNECTED); statusUpdate(UPID(), update, UPID()); } } return; }