diff --git a/dss-orchestrator/orchestrators/dss-workflow/dss-linkis-node-execution/src/main/java/com/webank/wedatasphere/dss/linkis/node/execution/service/impl/BuildJobActionImpl.java b/dss-orchestrator/orchestrators/dss-workflow/dss-linkis-node-execution/src/main/java/com/webank/wedatasphere/dss/linkis/node/execution/service/impl/BuildJobActionImpl.java index c914503bf2..a74ffeefeb 100644 --- a/dss-orchestrator/orchestrators/dss-workflow/dss-linkis-node-execution/src/main/java/com/webank/wedatasphere/dss/linkis/node/execution/service/impl/BuildJobActionImpl.java +++ b/dss-orchestrator/orchestrators/dss-workflow/dss-linkis-node-execution/src/main/java/com/webank/wedatasphere/dss/linkis/node/execution/service/impl/BuildJobActionImpl.java @@ -217,9 +217,9 @@ private void replaceSparkConfParams(Map paramMapCopy) throws Lin startupMap.remove("spark.executor.cores"); startupMap.remove("spark.executor.instances"); startupMap.remove("wds.linkis.engineconn.java.driver.memory"); + startupMap.remove("spark.conf"); startupMap.remove("mapreduce.job.running.map.limit"); startupMap.remove("mapreduce.job.running.reduce.limit"); - startupMap.remove("spark.conf"); logger.info("after remove startup map:{}",startupMap.keySet()); } Map configurationMap = TaskUtils.getMap(paramMapCopy, TaskConstant.PARAMS_CONFIGURATION);