Method Init

be/src/runtime/query-state.cc:166–317

}

Status QueryState::Init(const ExecQueryFInstancesRequestPB* exec_rpc_params,
    const TExecPlanFragmentInfo& fragment_info) {
  std::lock_guard<std::mutex> l(init_lock_);
  // Decremented in QueryExecMgr::StartQueryHelper() on success or by the caller of
  // Init() on failure. We need to do this before any returns because Init() always
  // returns a resource refcount to its caller.
  AcquireBackendResourceRefcount();

  if (IsCancelled()) return Status::CANCELLED;

  RETURN_IF_ERROR(DebugAction(query_options(), "QUERY_STATE_INIT"));

  ExecEnv* exec_env = ExecEnv::GetInstance();

  RuntimeProfile* jvm_host_profile = RuntimeProfile::Create(&obj_pool_, "JVM", false);
  host_profile_->AddChild(jvm_host_profile);

  int64_t gc_count = JvmMemoryCounterMetric::GC_COUNT->GetValue();
  PROFILE_GcCount.Instantiate(jvm_host_profile,
      [gc_count]() {
        return JvmMemoryCounterMetric::GC_COUNT->GetValue() - gc_count;
      });

  int64_t gc_time_millis = JvmMemoryCounterMetric::GC_TIME_MILLIS->GetValue();
  PROFILE_GcTimeMillis.Instantiate(jvm_host_profile,
      [gc_time_millis]() {
        return JvmMemoryCounterMetric::GC_TIME_MILLIS->GetValue() - gc_time_millis;
      });

  int64_t gc_num_warn_threshold_exceeded =
      JvmMemoryCounterMetric::GC_NUM_WARN_THRESHOLD_EXCEEDED->GetValue();
  PROFILE_GcNumWarnThresholdExceeded.Instantiate(jvm_host_profile,
      [gc_num_warn_threshold_exceeded]() {
        return JvmMemoryCounterMetric::GC_NUM_WARN_THRESHOLD_EXCEEDED->GetValue()
            - gc_num_warn_threshold_exceeded;
      });

  int64_t gc_num_info_threshold_exceeded =
      JvmMemoryCounterMetric::GC_NUM_INFO_THRESHOLD_EXCEEDED->GetValue();
  PROFILE_GcNumInfoThresholdExceeded.Instantiate(jvm_host_profile,
      [gc_num_info_threshold_exceeded]() {
        return JvmMemoryCounterMetric::GC_NUM_INFO_THRESHOLD_EXCEEDED->GetValue()
            - gc_num_info_threshold_exceeded;
      });

  int64_t gc_total_extra_sleep_time_millis =
      JvmMemoryCounterMetric::GC_TOTAL_EXTRA_SLEEP_TIME_MILLIS->GetValue();
  PROFILE_GcTotalExtraSleepTimeMillis.Instantiate(jvm_host_profile,
      [gc_total_extra_sleep_time_millis]() {
        return JvmMemoryCounterMetric::GC_TOTAL_EXTRA_SLEEP_TIME_MILLIS->GetValue()
            - gc_total_extra_sleep_time_millis;
      });

  // Initialize resource tracking counters.
  if (query_ctx().trace_resource_usage) {
    SystemStateInfo* system_state_info = exec_env->system_state_info();
    host_profile_->AddSamplingTimeSeriesCounter(
        "HostCpuUserPercentage", TUnit::BASIS_POINTS, [system_state_info] () {