Skip to content

Commit

Permalink
add template override params mapreduce.job.running.map.limit and mapr…
Browse files Browse the repository at this point in the history
…educe.job.running.reduce.limit
  • Loading branch information
SunPengWan committed Apr 9, 2024
1 parent 845104d commit c0e7c13
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -217,9 +217,9 @@ private void replaceSparkConfParams(Map<String, Object> 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<String, Object> configurationMap = TaskUtils.getMap(paramMapCopy, TaskConstant.PARAMS_CONFIGURATION);
Expand Down

0 comments on commit c0e7c13

Please sign in to comment.