Spring Cloud Task 参数不会传播到 Spring Batch 作业参数

Question

我正在从普通的spring批处理迁移到spring云任务，并通过spring云数据流执行spring批处理。在我的工作和我为file injest部署的示例工作中，我都遇到了以下问题:

https://docs.spring.io/spring-cloud-dataflow-samples/docs/current/reference/htmlsingle/#_batch_file_ingest

我使用的是带有postgres后端的spring-cloud-dataflow-server-local-1.0.RELEASE。我还修改了该示例以使用postgres数据库。

当我尝试使用不同的参数再次运行该任务时，出现了问题。当我第一次运行它时:

task launch fileInjectTask --arguments "filePath=classpath:data.csv --spring.cloud.task.closecontext_enable=false"

以下是日志中的输出：

2018-03-22 10:10:51.446 INFO 10431---[main]o.s.b.a.b.JobLauncherCommandLineRunner:运行默认命令行：[filePath=classpath：data.csv，--spring.cloud.task.closecontext_enable=false，--spring.cloud.task.executionid=13]

2018-03-22 10:10:51.497 INFO 10431---[main]o.s.b.c.l.support.SimpleJobLauncher:Job:[FlowJob:[name=intakeJob]]使用以下参数启动：〔｛filePath=classpath：data.csv，-spring.cloud.task.executionid=13，-springe.cloud.ttask.closecontext_enable=false，run.id＝1｝〕

这很好，参数被传递给批处理作业。现在，当我尝试用不同的参数运行同一个任务时：

task launch fileInjectTask --arguments "filePath=/home/hmcmanus/spring-cloud-dataflow-samples/batch/file-ingest/src/main/resources/data.csv --spring.cloud.task.closecontext_enable=false"

我在日志中看到了以下内容：

2018-03-22 10：12：18.249 信息 10554 --- [ main] o.s.b.a.b.JobLauncherCommandLineRunner ： 运行默认命令行： [filePath=/home/hmcmanus/spring-cloud-dataflow-samples/batch/file-ingest/src/main/resources/data.csv， --spring.cloud.task.closecontext_enable=false， --spring.cloud.task.executionid=14]

2018-03-22 10:12:18.322 INFO 10554-[main]o . s . b . c . l . support . simplejoblauncher:Job:[flow Job:[name = ingestJob]]用以下参数启动:[{filePath=classpath:data.csv，-spring . cloud . task . execution id = 13，run.id=1，-spring . cloud . task . close context _ enable = false }]

正如您在第二个示例中看到的，任务的参数是正确的，但是批处理作业的参数是任务执行的旧参数。

这里有我遗漏的东西吗？为什么Spring批处理作业不获取新任务执行的参数？

更新

为了排除数据库中的差异以及为使其运行而需要进行的任何修改，我还验证了数据流服务器和任务的嵌入式H2数据库具有相同的功能。

Answer 1

我在那个例子中遇到了同样的情况。到目前为止，我已经意识到正在使用任务的第一个执行ID作为参数来执行作业，在您的例子中是task.executionid=13。此值不会在作业执行过程中更改。根据春云任务参考：

Spring Boot 提供了在 über-jar 中轻松执行批处理作业的工具。Spring Boot 对此功能的支持允许开发人员在该执行中执行多个批处理作业。Spring Cloud Task 提供了将作业的执行（作业执行）与任务的执行相关联的能力，以便可以追溯到另一个。

此功能是通过使用TaskBatchExecutionListener来实现的。默认情况下，此侦听器在配置了Spring Batch作业（通过在上下文中定义作业类型的bean）和类路径中可用的spring-cloud d-task-batjar的任何上下文中自动配置。侦听器将被注入到所有作业中。

https://docs.spring.io/spring-cloud-task/current-SNAPSHOT/reference/htmlsingle/#batch-association

然而，在这个例子中，需求被包含在内。