The problem is the script doesn't use spark, but is called with SparkSubmitOperator. It needs to be called with SimpleSkeinOperator instead
Description
Description
Details
Details
Related Changes in GitLab:
| Title | Reference | Author | Source Branch | Dest Branch | |
|---|---|---|---|---|---|
| Use SimpleSkeinOperator instead of SparkSubmitOperator for data check | repos/data-engineering/airflow-dags!406 | cparle | T337410 | main |
Event Timeline
Comment Actions
cparle opened https://gitlab.wikimedia.org/repos/data-engineering/airflow-dags/-/merge_requests/406
Use SimpleSkeinOperator instead of SparkSubmitOperator for data check
Comment Actions
mfossati merged https://gitlab.wikimedia.org/repos/data-engineering/airflow-dags/-/merge_requests/406
Use SimpleSkeinOperator instead of SparkSubmitOperator for data check