Как я могу подключиться к локально развернутому спарку через airflow?

Я пытаюсь запустить джобу спарка через эирфлоу, используя следующий код:

spark = (SparkSession
            .builder
            .master("spark://172.22.102.229:7077")
            .appName("Test")
            .getOrCreate())

Но получаю ошибку

py4j.protocol.Py4JJavaError: An error occurred while calling None.org.apache.spark.api.java.JavaSparkContext.
: java.lang.IllegalArgumentException: requirement failed: Can only call getServletHandlers on a running MetricsSystem

Когда я меняю .master("spark://172.22.102.229:7077") на .master("local") это работает

Спарк развернут и доступен по адресу http://172.22.102.229:4040/


Ответы (0 шт):