Method GetRuntimeProfileOutput

be/src/service/impala-server.cc:808–843

}

Status ImpalaServer::GetRuntimeProfileOutput(const string& user,
    const QueryHandle& query_handle, TRuntimeProfileFormat::type format,
    RuntimeProfileOutput* profile) {
  // For queries in INITIALIZED state, the profile information isn't populated yet.
  if (query_handle->exec_state() == ClientRequestState::ExecState::INITIALIZED) {
    return Status::Expected("Query plan is not ready.");
  }
  lock_guard<mutex> l(*query_handle->lock());
  int64_t start_time_ns = MonotonicNanos();
  RETURN_IF_ERROR(CheckProfileAccess(
      user, query_handle->effective_user(), query_handle->user_has_profile_access()));
  if (query_handle->GetCoordinator() != nullptr) {
    UpdateExecSummary(query_handle);
  }
  if (format == TRuntimeProfileFormat::BASE64) {
    RETURN_IF_ERROR(
        query_handle->profile()->SerializeToArchiveString(profile->string_output));
  } else if (format == TRuntimeProfileFormat::THRIFT) {
    query_handle->profile()->ToThrift(profile->thrift_output);
  } else if (format == TRuntimeProfileFormat::JSON) {
    query_handle->profile()->ToJson(profile->json_output);
  } else {
    DCHECK_EQ(format, TRuntimeProfileFormat::STRING);
    query_handle->profile()->PrettyPrint(profile->string_output);
  }
  int64_t elapsed_time_ns = MonotonicNanos() - start_time_ns;
  if (elapsed_time_ns > FLAGS_slow_profile_dump_warning_threshold_ms * 1000 * 1000) {
    LOG(WARNING) << "Slow in dumping " << format << " profile of "
        << PrintId(query_handle->query_id()) << ". User " << user
        << " held the lock for " << PrettyPrinter::Print(elapsed_time_ns, TUnit::TIME_NS)
        << " (" << elapsed_time_ns << "ns). This might block client in fetching query "
        << "results.";
  }
  query_handle->UpdateGetInFlightProfileTime(elapsed_time_ns);
  return Status::OK();
}

Status ImpalaServer::GetQueryRecord(const TUniqueId& query_id,
    shared_ptr<QueryStateRecord>* query_record,