simple test DAG

This commit is contained in:
Giambattista Bloisi 2024-03-09 23:34:51 +01:00
parent 07f8645a60
commit 222b5e66c6
1 changed files with 40 additions and 1 deletions

View File

@ -65,7 +65,46 @@ dag = DAG(
submit = SparkKubernetesOperator(
task_id='spark_pi_submit',
namespace='lot1-spark-jobs',
application_file="example_spark_kubernetes_operator_pi.yaml",
template_spec="""apiVersion: "sparkoperator.k8s.io/v1beta2"
kind: SparkApplication
metadata:
name: spark-pi
namespace: lot1-spark-jobs
spec:
type: Scala
mode: clusterß
image: "apache/spark:v3.1.3"
imagePullPolicy: Always
mainClass: org.apache.spark.examples.SparkPi
mainApplicationFile: "local:///opt/spark/examples/jars/spark-examples_2.12-3.1.3.jar"
sparkVersion: "3.1.3"
restartPolicy:
type: Never
volumes:
- name: "test-volume"
hostPath:
path: "/tmp"
type: Directory
driver:
cores: 1
coreLimit: "1200m"
memory: "512m"
labels:
version: 3.1.3
serviceAccount: spark
volumeMounts:
- name: "test-volume"
mountPath: "/tmp"
executor:
cores: 1
instances: 1
memory: "512m"
labels:
version: 3.1.3
volumeMounts:
- name: "test-volume"
mountPath: "/tmp"
""",
kubernetes_conn_id="kubernetes_default",
do_xcom_push=True,
in_cluster=True,