Как передать внешний файл конфигурации в программу pyspark (Spark 2.x)? - PullRequest
0 голосов
/ 30 октября 2018

Когда я запускаю интерактивную оболочку программы pyspark, которая может извлечь файл конфигурации (config.ini) из сценария pyspark, Но когда я пытаюсь запустить тот же сценарий, используя команду Spark submit с мастер-пряжей, а режим развертывания кластера - кластер, он выдает ошибку, поскольку файл конфигурации не существует, я проверил журнал пряжи и могу увидеть то же самое, ниже приведена команда для запуска pyspark. работа.

spark2-submit --master yarn --deploy-mode cluster test.py /home/sys_user/ask/conf/config.ini

1 Ответ

0 голосов
/ 30 ноября 2018

С помощью команды spark2-sumbmit существует файл свойств, предоставленный параметром, который можно использовать для получения этого файла свойств, доступного в команде spark-submit.

например. spark2-submit - master yarn --deploy-mode cluster - файл свойств $ CONF_FILE_NAME pyspark_script.py

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...