Method KillQuery

be/src/service/control-service.cc:272–280

}

void ControlService::KillQuery(const KillQueryRequestPB* request,
    KillQueryResponsePB* response, RpcContext* rpc_context) {
  // Currently, we only support killing one query in one KILL QUERY statement.
  DCHECK_EQ(request->query_ids_size(), 1);
  const TUniqueId& query_id = ProtoToQueryId(request->query_ids(0));
  Status status = ExecEnv::GetInstance()->impala_server()->KillQuery(
      query_id, request->requesting_user(), request->is_admin());
  RespondAndReleaseRpc(vector{status}, response, rpc_context);
}
}