Method CancelQueries

be/src/runtime/query-exec-mgr.cc:241–249

}

void QueryExecMgr::CancelQueries(const QueryCancellationTask& to_cancel) {
  QueryState* qs = to_cancel.GetQueryState();
  DCHECK(qs != nullptr);
  if (qs == nullptr) return;
  VLOG(1) << "CancelFromThreadPool(): cancel query " << PrintId(qs->query_id());
  qs->Cancel();
  qs->is_coord_active_.Store(to_cancel.IsCoordActive());
  ReleaseQueryState(qs);
}

bool QueryExecMgr::ProcessCancelQueries(
    const vector<QueryCancellationTask>& to_cancel, bool handle_full_queue) {