[hotfix] fix typo of spark operator (#387)

flink-extended · Oct 9, 2022 · 4cba536 · 4cba536
1 parent cb7c3be
commit 4cba536
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/ai_flow/operators/spark/spark_submit.py b/ai_flow/operators/spark/spark_submit.py
@@ -165,7 +165,7 @@ def _get_executable_path(self):
         if self._executable_path:
             spark_submit = self._executable_path
         elif shutil.which('spark-submit') is not None:
-            spark_submit = shutil.which('spark_submit')
+            spark_submit = shutil.which('spark-submit')
             self.log.info(f"Using {spark_submit} in PATH")
         else:
             spark_submit = expand_env_var('${SPARK_HOME}/bin/spark-submit')