diff --git a/src/main/java/io/kestra/plugin/spark/PythonSubmit.java b/src/main/java/io/kestra/plugin/spark/PythonSubmit.java index 54b3eaa..742896f 100644 --- a/src/main/java/io/kestra/plugin/spark/PythonSubmit.java +++ b/src/main/java/io/kestra/plugin/spark/PythonSubmit.java @@ -38,7 +38,7 @@ " user: root", "master: spark://localhost:7077", "args:", - "- \"10\"", + " - \"10\"", "mainScript: |", " import sys", " from random import random", diff --git a/src/main/java/io/kestra/plugin/spark/SparkCLI.java b/src/main/java/io/kestra/plugin/spark/SparkCLI.java index a65a314..738c88f 100644 --- a/src/main/java/io/kestra/plugin/spark/SparkCLI.java +++ b/src/main/java/io/kestra/plugin/spark/SparkCLI.java @@ -35,7 +35,7 @@ title = "Submit a PySpark job to a master node.", full = true, code = """ - id: spark-cli + id: spark_cli namespace: company.team tasks: - id: hello