diff --git a/frameworks/spark/dispatcher/src/main/scala/org/apache/amaterasu/frameworks/spark/dispatcher/runners/providers/PySparkRunnerProvider.scala b/frameworks/spark/dispatcher/src/main/scala/org/apache/amaterasu/frameworks/spark/dispatcher/runners/providers/PySparkRunnerProvider.scala
index 0b7ed21..2c718d9 100644
--- a/frameworks/spark/dispatcher/src/main/scala/org/apache/amaterasu/frameworks/spark/dispatcher/runners/providers/PySparkRunnerProvider.scala
+++ b/frameworks/spark/dispatcher/src/main/scala/org/apache/amaterasu/frameworks/spark/dispatcher/runners/providers/PySparkRunnerProvider.scala
@@ -10,7 +10,7 @@
     val command = super.getCommand(jobId: String, actionData: ActionData, env: String, executorId: String, callbackAddress: String)
     log.info(s"===> Cluster manager: ${conf.mode}")
     command +
-      //s" $$SPARK_HOME/conf/spark-env.sh &&" +
+      //s" $$SPARK_HOME/conf/spark-env.sh" +
       s" && env PYSPARK_PYTHON=$getVirtualPythonPath" +
       s" && $$SPARK_HOME/bin/spark-submit ${actionData.getSrc}"
   }