DEV Community: Enamul Haque

Spring batch job is already running not working

Enamul Haque — Mon, 12 Feb 2024 04:37:50 +0000

I am using spring batch 5. I need to stop running the batch again if it is already running. I have tried bellow like

@Component
@RequiredArgsConstructor
@Slf4j
public class RtgsJob {
private final ProcessorStep1 batchProcessorStep1;
private final WriterStep1 batchWriterStep1;
private final PlatformTransactionManager transactionManager;
private final JobRepository jobRepository;

  public Job createEft(){

        return new JobBuilder("RTGS-STEP1", jobRepository)
                .incrementer(new RunIdIncrementer())
                .start(step1())
                .build();


    }


    private Step step1(){

        return new StepBuilder("step1", jobRepository)
                .<input, output> chunk(10, transactionManager)
                .reader(new ReaderStep1())
                .processor(batchProcessorStep1)
                .writer(batchWriterStep1)
                .build();
    }


}

Job Schdule run the job:

@Component
@Slf4j
public class ScheduledJobBean {

    @Autowired
    JobLauncher jobLauncher;

    @Autowired
    RtgsJob eftJob;

    @Autowired
    private  JobRepository jobRepository;

     @Scheduled(cron = "*/30* * * * *")
    public void perform() throws Exception
    {
        JobExecution lastJobExecutionStep1 = jobRepository.getLastJobExecution("RTGS-STEP1", new JobParametersBuilder().toJobParameters());

        if (lastJobExecutionStep1 == null || lastJobExecutionStep1.getStatus().isLessThan(BatchStatus.STARTING)) {

            log.info("{} batch step1 {} executionTransaction {} Started ");

            try {

                JobParameters jobParameters2 = new JobParametersBuilder()
                        .addLong("startAtRTGSStep1", System.currentTimeMillis())
                        .toJobParameters();
                executionTransaction =   jobLauncher.run(eftJob.createEft(),jobParameters2);



            } catch (JobExecutionAlreadyRunningException | JobRestartException | JobInstanceAlreadyCompleteException |
                     JobParametersInvalidException ex) {

                log.error("{} rtgs batch {} Step1 {} executionTransaction {} JobExecutionAlreadyRunningException | JobRestartException | JobInstanceAlreadyCompleteException | JobParametersInvalidException message: "+ex.getMessage());
                ex.printStackTrace();


            }catch (Exception ex) {

                log.error("{} rtgs batch {} Step1 executionTransaction {} error: "+ex.getMessage());
                ex.printStackTrace();
                log.error(ex.getMessage());


            }
        }else{
            log.info("{} rtgs batch step1 {} execution {} isRunning ");
        }



    }
}

My job started after 30 second. if one job is running it won't start again until it is completed. That means if data process need more than 30 second it won't start again. After completed pressing it will start within 30 second again

But above configuration batch start again within 30 second if one batch is already running.

What is the wrong of my configuration?

please help me

how to run run synchronously two batch in spring batch?

Enamul Haque — Wed, 17 Jan 2024 05:33:57 +0000

Hi sir,
I am Enamul working spring batch 5. In my case Spring batch running in spring schedule. But my deployment server has multiple instances. When it is running, it make double transaction in database. That means it occurs multiple transaction which occurs miss mass of my transaction.

I have two batch. I need processes thousand of transaction using batch.I need to run both batches synchronous. One batch is started it won't get any request until complete. If both batch completed then start again.

Here is my batch configuration:

public class RtgsJob {

        public Job createEft(){

            String id = UUID.randomUUID().toString();
            id = "RTGS-STEP1-"+id;
            return new JobBuilder(id, jobRepository)
                    .incrementer(new RunIdIncrementer())
                    .start(step1())
                    .build();

        }


        public Job createEftTransaction(){
            String id = UUID.randomUUID().toString();
            id = "RTGS-STEP2-"+id;
            return new JobBuilder(id, jobRepository)
                    .incrementer(new RunIdIncrementer())
                    .flow(step2())
                    .end()
                    .build();



        }

        private Step step1(){

            return new StepBuilder("step1", jobRepository)
                    .<mydata, mydata> chunk(10, transactionManager)
                    .reader(myReader)
                    .processor(myProcessor)
                    .writer(myWritter)
                    .build();
        }

        private Step step2(){

            return new StepBuilder("step2", jobRepository)
                    .<mydata, mydata> chunk(10, transactionManager)
                    .reader(myReader)
                    .processor(myProcessor)
                    .writer(myWritter)
                    .build();
        }

}

Here is my schedule code:

JobExecution execution = null;
    JobExecution executionTransaction = null;

    if(execution == null) {
        // rtgs batch step1 {} execution {} Started: 
        try {
            execution = jobLauncher.run(eftJob.createEft(), new JobParameters());

           // rtgs batch {} Step1 existStatus: "+execution.getExitStatus()

        } catch (JobExecutionAlreadyRunningException | JobRestartException | JobInstanceAlreadyCompleteException |
                 JobParametersInvalidException ex) {

            ex.printStackTrace();
        }catch (Exception ex) {
            ex.printStackTrace();

        }



        if(execution.getExitStatus().getExitCode().equals("COMPLETED")){

            if(executionTransaction == null){
                log.info(Constants.batchTag + "{} rtgs batch step2 {} executionTransaction {} Started: ");

                try {
                    executionTransaction =   jobLauncher.run(eftJob.createEftTransaction(),new JobParameters());

                    //{} rtgs batch step2 {} executionTransaction {} Completed;

                } catch (JobExecutionAlreadyRunningException | JobRestartException | JobInstanceAlreadyCompleteException |
                         JobParametersInvalidException ex) {

                    ex.printStackTrace();
                }catch (Exception ex) {

                    ex.printStackTrace();


                }
            }
        }


    }else{
        //{} rtgs batch step1 {} execution {} isRunning: ;
    }

How to solve the problem?

Please help me..