Airflow cant execute SparkSubmit

Viewed 14

I am trying SparkSubmitOperator in Airflow

My job run by jar file, with config in config.properties by typesafe.ConfigFactory
My error is: airflow.exceptions.AirflowException: Cannot execute: /home/hungnd/spark-2.4.3-bin-hadoop2.7/bin/spark-submit

--master yarn

--conf spark.executor.extraClassPath=file:///home/hungnd/airflow/dags/project/spark-example/config.properties

--files /home/hungnd/airflow/dags/project/spark-example/config.properties

--driver-class-path file:///home/hungnd/airflow/dags/project/spark-example/config.properties

--jars file:///home/hungnd/airflow/dags/project/spark-example/target/libs/*

--name arrow-spark

--class vn.vccorp.adtech.analytic.Main

--queue root.default

--deploy-mode client

/home/hungnd/airflow/dags/project/spark-example/target/spark-example-1.0-SNAPSHOT.jar

But I copy that command to server ubuntu, it run successfully

Please help me!! Thank

0 Answers
Related