스프링 부트 JobOperator.stop (executionId) 및 JobOperator.restart (executionId) 동작

Question

배치 작업을 처리하기 위해 Spring 배치를 사용하려고합니다. 내가 stop에 executionId을 사용하여 실행중인 작업을하려고하면 는 작업이 2017년 11월 27일 11시 39분 ',

'104 ','3 ','104 'SpringBatchDb.BATCH_JOB_EXECUTION 표에 아래의 항목과 정지 : 10 ','2017-11-27 11:39:10 ','2017-11-27 11:39:48 ','STOPPED ','STOPPED ','org.springframework.batch.core.JobInterruptedException ',' 2017년 11월 27일 11 : 39 다음 STATUS 및 EXIT_CODE가 STOPPED으로 업데이트됩니다 NULL (48) ',

참고. 그러나 예외로 throw합니다 : org.springframework.batch.core.launch.NoSuchJobException: No job configuration with the name [testJob] was registered at org.springframework.batch.core.configuration.support.MapJobRegistry.getJob(MapJobRegistry.java:66) at org.springframework.batch.core.launch.support.SimpleJobOperator.restart(SimpleJobOperator.java:275) at org.springframework.batch.core.launch.support.SimpleJobOperator$$FastClassBySpringCGLIB$$44ee6049.invoke(<generated>) at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:204) at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:669) at org.springframework.batch.core.launch.support.SimpleJobOperator$$EnhancerBySpringCGLIB$$318ff269.restart(<generated>) at com.test.mypackage.batch.dao.BatchJobDaoImpl.restartJobExecution(BatchJobDaoImpl.java:62).

executionId를 사용하여 동일한 작업을 다시 시작하려고하면 시작되지 않고 동일한 예외가 발생합니다 (위 그림 참조).

내 코드는 여기에 무슨 잘못

@Autowired 
private DataSource dataSource; 
@Autowired 
private JobOperator jobOperator; 
@Override 
public Long stopRunningExecution(Long executionId) throws NoSuchJobExecutionException, JobExecutionNotRunningException { 
    jobOperator.stop(executionId); 
    return executionId; 
} 
@Override 
public Long restartJobExecution(long executionId) throws JobParametersInvalidException, JobRestartException, JobInstanceAlreadyCompleteException, NoSuchJobExecutionException, NoSuchJobException { 
    return jobOperator.restart(executionId); 
} 

매우 간단하다?

Answer 1

비슷한 오류가 발생했지만 문제를 해결할 수있었습니다.

JobRegistry를 정의하지 않았으므로 문제가 발생합니다. JobRegistry를 정의하고이를 JobOperator Bean에 추가하면 위의 예외는 발생하지 않습니다. 예를 들어

:

@Bean 
public JobRegistry jobRegistry() { 
    return new MapJobRegistry(); 
} 

@Bean 
public JobRegistryBeanPostProcessor jobRegistryBeanPostProcessor() { 
    JobRegistryBeanPostProcessor jobRegistryBeanPostProcessor = new JobRegistryBeanPostProcessor(); 
    jobRegistryBeanPostProcessor.setJobRegistry(jobRegistry()); 
    return jobRegistryBeanPostProcessor; 
} 

@Bean 
public JobOperator jobOperator() { 
    SimpleJobOperator jobOperator = new SimpleJobOperator(); 
    jobOperator.setJobExplorer(getJobExplorer()); 
    jobOperator.setJobRepository(getJobRepository()); 
    jobOperator.setJobLauncher(getJobLauncher()); 
    jobOperator.setJobRegistry(jobRegistry()); 

    return jobOperator; 
}