Method Maintenance

be/src/scheduling/executor-blacklist.cc:104–131

}

void ExecutorBlacklist::Maintenance(std::list<BackendDescriptorPB>* probation_list) {
  int64_t blacklist_timeout = GetBlacklistTimeoutMs();
  int64_t probation_timeout = blacklist_timeout * PROBATION_TIMEOUT_MULTIPLIER;
  int64_t now = MonotonicMillis();
  auto entry_it = executor_list_.begin();
  while (entry_it != executor_list_.end()) {
    Entry& entry = entry_it->second;
    int64_t elapsed = now - entry.blacklist_time_ms;
    if (entry.state == State::BLACKLISTED) {
      // Check if we can take it off the blacklist and put it on probation.
      if (elapsed > blacklist_timeout * entry.num_consecutive_blacklistings) {
        LOG(INFO) << "Executor " << entry.be_desc.address()
                  << " passed the timeout and will be taken off the blacklist.";
        probation_list->push_back(entry.be_desc);
        entry.state = State::ON_PROBATION;
      }
      ++entry_it;
    } else {
      // Check if we can take it off probation.
      if (elapsed > probation_timeout * entry.num_consecutive_blacklistings) {
        entry_it = executor_list_.erase(entry_it);
      } else {
        ++entry_it;
      }
    }
  }
  VLOG(2) << "Completed blacklist maintenance. Current blacklist: " << DebugString();
}

bool ExecutorBlacklist::IsBlacklisted(
    const BackendDescriptorPB& be_desc, Status* cause, int64_t* time_remaining_ms) const {