diff --git a/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/batch/JobLauncherCommandLineRunner.java b/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/batch/JobLauncherCommandLineRunner.java index ec6c78e5511..37a9b4e1eee 100644 --- a/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/batch/JobLauncherCommandLineRunner.java +++ b/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/batch/JobLauncherCommandLineRunner.java @@ -181,8 +181,7 @@ public class JobLauncherCommandLineRunner Map merged = new HashMap(); merged.putAll(parameters.getParameters()); merged.putAll(additionals); - parameters = new JobParameters(merged); - return parameters; + return new JobParameters(merged); } private void executeRegisteredJobs(JobParameters jobParameters) @@ -199,7 +198,6 @@ public class JobLauncherCommandLineRunner } catch (NoSuchJobException ex) { logger.debug("No job found in registry for job name: " + jobName); - continue; } } } @@ -210,11 +208,9 @@ public class JobLauncherCommandLineRunner JobInstanceAlreadyCompleteException, JobParametersInvalidException, JobParametersNotFoundException { JobParameters nextParameters = getNextJobParameters(job, jobParameters); - if (nextParameters != null) { - JobExecution execution = this.jobLauncher.run(job, nextParameters); - if (this.publisher != null) { - this.publisher.publishEvent(new JobExecutionEvent(execution)); - } + JobExecution execution = this.jobLauncher.run(job, nextParameters); + if (this.publisher != null) { + this.publisher.publishEvent(new JobExecutionEvent(execution)); } }