SpringCloud/spring-cloud-task
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Resolved Batch Job Param reconfiguration for TaskJobApplicationRunner

Browse Source 
Resolved issue with EmbeddedKafka failure in tests

Updated all versions
This commit is contained in:
Glenn Renfro
2021-10-08 11:44:26 -04:00
committed by Glenn Renfro
parent dc1c8e5d66
commit fe0b754f35
12 changed files with 16 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
spring-cloud-task-batch/src/main/java/org/springframework/cloud/task/batch/handler/TaskJobLauncherApplicationRunner.java
View File

@@ -208,15 +208,15 @@ public class TaskJobLauncherApplicationRunner extends JobLauncherApplicationRunn
private JobParameters removeNonIdentifying(JobParameters parameters) {
Map<String, JobParameter> parameterMap = parameters.getParameters();
HashMap<String, JobParameter> copy = new HashMap<>(parameterMap);
HashMap<String, JobParameter> copy = new HashMap<>();
for (Map.Entry<String, JobParameter> parameter : copy.entrySet()) {
if (!parameter.getValue().isIdentifying()) {
parameterMap.remove(parameter.getKey());
for (Map.Entry<String, JobParameter> parameter : parameterMap.entrySet()) {
if (parameter.getValue().isIdentifying()) {
copy.put(parameter.getKey(), parameter.getValue());
}
}
return new JobParameters(parameterMap);
return new JobParameters(copy);
}
private boolean isStoppedOrFailed(JobExecution execution) {