| 1106 | |
| 1107 | |
| 1108 | void taskCompletionTimeout(const TaskID& taskId, const Duration& duration) |
| 1109 | { |
| 1110 | CHECK(!terminated); |
| 1111 | CHECK(!killed); |
| 1112 | |
| 1113 | LOG(INFO) << "Killing task " << taskId |
| 1114 | << " which exceeded its maximum completion time of " << duration; |
| 1115 | |
| 1116 | taskCompletionTimer = None(); |
| 1117 | killedByMaxCompletionTimer = true; |
| 1118 | |
| 1119 | // Use a zero gracePeriod to kill the task. |
| 1120 | kill(taskId, Duration::zero()); |
| 1121 | } |
| 1122 | |
| 1123 | |
| 1124 | // Use this helper to create a status update from scratch, i.e., without |