spark fixed

DonYum · Oct 9, 2020 · 30ce071 · 30ce071
1 parent 8017dc0
commit 30ce071
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/python/fate_flow/manager/resource_manager.py b/python/fate_flow/manager/resource_manager.py
@@ -255,8 +255,7 @@ def job_engine_support_parameters(cls, job_parameters: RunParameters):
             job_parameters.spark_run["num-executors"] = job_parameters.adaptation_parameters["task_nodes"]
 
             job_parameters.adaptation_parameters["task_cores_per_node"] = int(
-                job_parameters.spark_run.get("executor-cores", DEFAULT_TASK_CORES_PER_NODE))
-
+                job_parameters.spark_run.get("executor-cores", DEFAULT_TASK_CORES_PER_NODE))            
             job_parameters.spark_run["executor-cores"] = job_parameters.adaptation_parameters["task_cores_per_node"]
 
 #             job_parameters.adaptation_parameters["task_memory_per_node"] = int(