Method CancelQueriesForFailedCoordinators

be/src/runtime/query-exec-mgr.cc:276–286

}

void QueryExecMgr::CancelQueriesForFailedCoordinators(
    const unordered_set<BackendIdPB>& current_membership) {
  vector<QueryCancellationTask> to_cancel;
  CollectQueriesToCancel(
      [&](QueryState* qs) {
        return current_membership.find(qs->GetCoordinatorBackendId())
            == current_membership.end();
      },
      false /* is_coord_active */, &to_cancel);
  ProcessCancelQueries(to_cancel, true /* handle_full_queue */);
}

bool QueryExecMgr::CancelQueriesForGracefulShutdown() {
  vector<QueryCancellationTask> to_cancel;