Starts the impalad and waits until the service is ready to accept connections. 'timeout' is the amount of time to wait for the Impala server to be in the ready state.
(self, wait_until_ready=True, timeout=30)
| 651 | return self._get_arg_value("is_coordinator", "true") == "true" |
| 652 | |
| 653 | def start(self, wait_until_ready=True, timeout=30): |
| 654 | """Starts the impalad and waits until the service is ready to accept connections. |
| 655 | 'timeout' is the amount of time to wait for the Impala server to be in the |
| 656 | ready state.""" |
| 657 | restart_args = self.cmd[1:] |
| 658 | LOG.info("Starting Impalad process with args: {0}".format(restart_args)) |
| 659 | run_daemon("impalad", restart_args) |
| 660 | if wait_until_ready: |
| 661 | self.service.wait_for_metric_value('impala-server.ready', |
| 662 | expected_value=1, timeout=timeout) |
| 663 | |
| 664 | def wait_for_webserver(self, sleep_interval, early_abort_fn): |
| 665 | start_time = time.time() |
nothing calls this directly
no test coverage detected