Method ShutdownThread

be/src/service/impala-server.cc:3755–3790

}

[[noreturn]] void ImpalaServer::ShutdownThread() {
  while (true) {
    SleepForMs(1000);
    const ShutdownStatusPB& shutdown_status = GetShutdownStatus();
    LOG(INFO) << "Shutdown status: " << ShutdownStatusToString(shutdown_status);
    if (shutdown_status.grace_remaining_ms() <= 0
        && shutdown_status.backend_queries_executing() == 0
        && shutdown_status.client_requests_registered() == 0) {
      break;
    } else if (shutdown_status.deadline_remaining_ms() <= 0) {
      break;
    } else if (FLAGS_shutdown_query_cancel_period_s > 0
        && !shutdown_deadline_cancel_queries_
        && shutdown_status.cancel_deadline_remaining_ms() <= 0) {
      shutdown_deadline_cancel_queries_ = CancelQueriesForGracefulShutdown();
    }
  }

  // Clean up temporary files if needed.
  ExecEnv::GetInstance()->tmp_file_mgr()->CleanupAtShutdown();

  if (FLAGS_is_coordinator && FLAGS_otel_trace_enabled) {
    shutdown_otel_tracer();
  }

  // Drain the completed queries queue to the query log table.
  if (FLAGS_enable_workload_mgmt) {
    ShutdownWorkloadManagement();
  }

  LOG(INFO) << "Shutdown complete, going down.";
  // Use _exit here instead since exit() does cleanup which interferes with the shutdown
  // signal handler thread causing a data race.
  ShutdownLogging();
  _exit(0);
}

// This should never be inlined to prevent it potentially being optimized, e.g.
// by short-circuiting the comparisons.