Function main

be/src/service/internal-server-test.cc:569–613

} // namespace impala

int main(int argc, char** argv) {
  FLAGS_jni_frontend_class = "org/apache/impala/service/JniFrontend";

  FLAGS_hostname = "localhost";
  FLAGS_state_store_host = FLAGS_hostname;
  FLAGS_catalog_service_host = FLAGS_hostname;
  FLAGS_enable_webserver = true;

  FLAGS_hs2_port = 21055;
  FLAGS_hs2_http_port = 28005;
  FLAGS_krpc_port = 27005;
  FLAGS_state_store_subscriber_port = 23005;
  FLAGS_webserver_port = 25005;

  // Provides information about the current thread in a minidump if one is generated.
  ThreadDebugInfo debugInfo;

  testing::InitGoogleTest(&argc, argv);
  InitCommonRuntime(argc, argv, true, TestInfo::BE_CLUSTER_TEST);
  ABORT_IF_ERROR(LlvmCodeGen::InitializeLlvm(argv[0]));
  JniUtil::InitLibhdfs();
  ABORT_IF_ERROR(JniCatalogCacheUpdateIterator::InitJNI());
  InitFeSupport();

  ExecEnv exec_env;
  ABORT_IF_ERROR(exec_env.Init());

  impala_server_ = make_shared<ImpalaServer>(&exec_env);
  ABORT_IF_ERROR(impala_server_->Start(FLAGS_beeswax_port, FLAGS_hs2_port,
      FLAGS_hs2_http_port, 0));

  EXPECT_TRUE(impala_server_->IsCoordinator());
  EXPECT_TRUE(impala_server_->IsExecutor());
  exec_env.frontend()->WaitForCatalog();

  ABORT_IF_ERROR(WaitForServer(FLAGS_hostname, FLAGS_hs2_port, 10, 100));

  int test_ret_val = RUN_ALL_TESTS();

  ShutdownStatusPB shutdown_status;
  ABORT_IF_ERROR(impala_server_->StartShutdown(5, &shutdown_status));
  impala_server_->Join();

  return test_ret_val;
}