def run_master(self):
        self._logger.info('Running master on {}'.format(self._master_url))
        if self.is_master_up():
            return
        cmd = [self._main_executable, 'master', '--port', self._port(self._master_url)]

        self._run_service(cmd, self._master_url)
Start parameter server
dataset/ETHPy150Open box/ClusterRunner/app/client/service_runner.py/ServiceRunner.run_master--crossover with--dataset/ETHPy150Open maxpumperla/elephas/elephas/spark_model.py/SparkModel.start_server