| 86 | } |
| 87 | |
| 88 | Status InProcessImpalaServer::StartWithClientServers( |
| 89 | int beeswax_port, int hs2_port, int hs2_http_port) { |
| 90 | RETURN_IF_ERROR(exec_env_->Init()); |
| 91 | beeswax_port_ = beeswax_port; |
| 92 | hs2_port_ = hs2_port; |
| 93 | hs2_http_port_ = hs2_http_port; |
| 94 | |
| 95 | impala_server_.reset(new ImpalaServer(exec_env_.get())); |
| 96 | SetCatalogIsReady(); |
| 97 | RETURN_IF_ERROR(impala_server_->Start(beeswax_port, hs2_port, hs2_http_port_, 0)); |
| 98 | |
| 99 | // Wait for up to 1s for the backend server to start |
| 100 | RETURN_IF_ERROR(WaitForServer(FLAGS_hostname, krpc_port_, 10, 100)); |
| 101 | return Status::OK(); |
| 102 | } |
| 103 | |
| 104 | Status InProcessImpalaServer::Join() { |
| 105 | impala_server_->Join(); |
no test coverage detected