Spring Batch Job 获取先前的执行参数

Question

我正在使用 Spring Cloud 数据流并创建了一个包含作业的 Spring Cloud 任务。该作业有一个名为 last_modified_date 的参数，它是可选的。在代码中，我已经指定了在 last_modified_date 为空的情况下取哪个日期，也就是说，它没有作为参数传递。问题是，如果对于作业的一个实例我传递了 last_modified_date 但对于下一个我没有传递，它会在最后一次执行中选择一个，而不是将它作为 null 传递并从代码中获取它。

@Component
@StepScope
public class SalesforceAdvertiserLoadTasklet implements Tasklet {

  @Value("#{jobParameters['last_modified_date']}")
  protected Date lastModifiedDate;

  private static final Logger logger =
      LoggerFactory.getLogger(SalesforceAdvertiserLoadTasklet.class);

  @Override
  public RepeatStatus execute(StepContribution contribution, ChunkContext chunkContext)
      throws Exception {

    if(lastModifiedDate == null) {
      lastModifiedDate =
          Date.from(LocalDate.now().minusDays(1).atStartOfDay(ZoneId.systemDefault()).toInstant());
    }
    logger.info("In Method: runSalesforceAdvertiserLoadJob launch started on last_modified_date {}",
        lastModifiedDate);

    logger.info("Getting advertisers from SalesForce");
    try {
      getAdvertisersFromSalesforceAndAddtoDb();
    } catch (JsonSyntaxException | IOException | ParseException e) {
      logger.error("ERROR--> {}", e.getMessage());
    }
    return RepeatStatus.FINISHED;
  }

@Bean
  public JobParametersIncrementer runIdIncrementor() {
    return new RunIdIncrementer();
  }

@Bean
  public Job salesforceAdvertiserLoadJob() {
    return jobBuilderFactory.get(SalesforceJobName.salesforceAdvertiserLoadJob.name())
        .incrementer(runIdIncrementor())
        .listener(batchJobsExecutionListener)
        .start(stepsConfiguration.salesforceAdvertiserLoadStep()).build();
  }

有什么方法可以阻止新作业实例从以前的作业实例中获取参数？

Answer 1

我认为您没有将JobParametersIncrementer 提供给您的JobBuilder。示例：

Job job = jobBuilderFactory.get(jobName)
    .incrementer(new RunIdIncrementer())
    .start(step)
    .end()
    .build();