| 1119 | } |
| 1120 | |
| 1121 | void lostExecutor( |
| 1122 | const UPID& from, |
| 1123 | const ExecutorID& executorId, |
| 1124 | const SlaveID& slaveId, |
| 1125 | int32_t status) |
| 1126 | { |
| 1127 | if (!running.load()) { |
| 1128 | VLOG(1) |
| 1129 | << "Ignoring lost executor message because the driver is not running!"; |
| 1130 | return; |
| 1131 | } |
| 1132 | |
| 1133 | if (!connected) { |
| 1134 | VLOG(1) |
| 1135 | << "Ignoring lost executor message because the driver is disconnected!"; |
| 1136 | return; |
| 1137 | } |
| 1138 | |
| 1139 | CHECK_SOME(master); |
| 1140 | if (from != master->pid()) { |
| 1141 | VLOG(1) << "Ignoring lost executor message because it was sent " |
| 1142 | << "from '" << from << "' instead of the leading master '" |
| 1143 | << master->pid() << "'"; |
| 1144 | return; |
| 1145 | } |
| 1146 | |
| 1147 | VLOG(1) |
| 1148 | << "Executor " << executorId << " on agent " << slaveId |
| 1149 | << " exited with status " << status; |
| 1150 | |
| 1151 | Stopwatch stopwatch; |
| 1152 | if (FLAGS_v >= 1) { |
| 1153 | stopwatch.start(); |
| 1154 | } |
| 1155 | |
| 1156 | scheduler->executorLost(driver, executorId, slaveId, status); |
| 1157 | |
| 1158 | VLOG(1) << "Scheduler::executorLost took " << stopwatch.elapsed(); |
| 1159 | } |
| 1160 | |
| 1161 | void frameworkMessage( |
| 1162 | const SlaveID& slaveId, |
nothing calls this directly
no test coverage detected