Relative Content

Tag Archive for apache-sparkairflowairflow-taskflowairflow-xcom

Airflow XCom Push from SparkSubmitOperator not working

I have an airflow job which launches a Spark job in one task and next task extract the application logs to find the spark job appplication Id . I am using Xcom push in the spark submit task and then xcom_pull in the next task