当前位置: 首页 > >

java clearparameters_使用jobparameters重新启动Spring批处理

发布时间:

我们遇到了同样的问题,对我而言,这看起来像是一个缺陷,特别是在比较SimpleJobLauncher如何评估上一个工作时 .


如您所述,getLasFailedJobExecution()不会考虑参数 . (至少在我看来,这是错误的 . 你可以使用不同的识别参数运行相同的工作,但只有其中一个运行失败才能重新启动 . )


另一方面,SimpleJobLauncher根据参数获取最后的作业执行:


public JobExecution run(final Job job, final JobParameters jobParameters)


throws JobExecutionAlreadyRunningException, JobRestartException, JobInstanceAlreadyCompleteException,


JobParametersInvalidException {


...


JobExecution lastExecution = jobRepository.getLastJobExecution(job.getName(), jobParameters);


...


这不一致 .


我们修复它的方法是实现我们自己的CommandLineJobRunner,它来自CommandLineJobRunner,但你必须覆盖整个start方法,因此,你必须复制几个私有方法 .


start方法中的整个*舨糠直匦敫谋淙缦拢


if (opts.contains("-restart")) {


JobExecution lastExecution = jobRepository.getLastJobExecution(job.getName(), jobParameters);


if (!jobExecution.getStatus().isGreaterThan(BatchStatus.STOPPING)) {


throw new JobExecutionNotFailedException("No failed or stopped execution found for job="


+ jobIdentifier);


}


jobParameters = jobExecution.getJobParameters();


jobName = jobExecution.getJobInstance().getJobName();


}


Edited


有时我真的应该阅读javadoc ......


如果重新启动,您可以传递executionid而不是jobname . 在这种情况下,它将找到正确的重新执行 .


从主方法的javadoch:


restart :(可选)如果作业失败或停止,则应重新启动 . 如果指定,则jobIdentifier参数可以解释为作业的名称或失败的作业执行的ID .


因此,在重新启动的情况下使用执行ID将确保重新启动正确的实例 . 在这种情况下,您也不必提供任何其他参数,因为它们将从上次执行中获取 .



友情链接: