将属性传递给春季云数据流组合任务运行程序的子任务

Question

我正在尝试运行spring云数据流的组合任务运行程序，其中包含两个子任务(A和B)。我将属性传递给我的-复合-任务，它也必须传递给子任务，但它不是传递到子应用程序中。下面是我使用的命令：

用于在数据流shell中创建任务：

task create my-composed-task --definition "A && B"

用于在数据流外壳中启动任务：

task launch my-composed-task --arguments "--spring.cloud.task.closecontextEnabled=true --increment-instance-enabled=true --composed-task-arguments=measurementyear=2020,--logging.level.org=ERROR,--spring.datasource.url=url,--spring.datasource.username=username,--spring.datasource.password=password" --properties "deployer.composed-task-runner.local.javaOpts=-Xmx8g"

属性参数"deployer.composed-task-runner.local.javaOpts=-Xmx8g"不进入my-composed-task.的子应用程序。

通过数据流shell启动后，服务器将显示以下命令，用于创建的任务：

我的-组合任务

o.s.c.d.spi.local.LocalTaskLauncher      : Command to be executed: C:\Program Files\jdk1.8.0_152\jre\bin\java.exe -Xmx8g -jar C:\Users\shivani.chittauri\Desktop\jar\composedtaskrunner-task-2.1.0.RELEASE.jar --spring.cloud.task.closecontextEnabled=true --composed-task-arguments=measurementyear=2020,--spring.messages.encoding=UTF-8,--logging.level.org=ERROR,--spring.datasource.url=url,--spring.datasource.username=username,--spring.datasource.password=password --increment-instance-enabled=true --spring.cloud.dataflow.task.platform.local.accounts.default.javaOpts=-Xmx8g --spring.cloud.data.flow.platformname=default --spring.cloud.task.executionid=49 --spring.cloud.data.flow.taskappname=composed-task-runner

它使用javaOpts作为-Xmx8g，这是正确的。

任务A

o.s.c.d.spi.local.LocalTaskLauncher      : Command to be executed: C:\Program Files\jdk1.8.0_152\jre\bin\java.exe -jar C:\Users\shivani.chittauri\Desktop\jar\A-1.0-SNAPSHOT.jar --spring.datasource.username=username --spring.datasource.url=url --spring.messages.encoding=UTF-8 --logging.level.org=ERROR --spring.datasource.password=password measurementyear=2020 --spring.cloud.data.flow.platformname=default --spring.cloud.task.executionid=50

它没有javaOpts，但是它应该有

任务B

o.s.c.d.spi.local.LocalTaskLauncher      : Command to be executed: C:\Program Files\jdk1.8.0_152\jre\bin\java.exe -jar C:\Users\shivani.chittauri\Desktop\jar\B-1.0-SNAPSHOT.jar --spring.datasource.username=username --spring.datasource.url=url --spring.messages.encoding=UTF-8 --logging.level.org=ERROR --spring.datasource.password=password measurementyear=2020 --spring.cloud.data.flow.platformname=default --spring.cloud.task.executionid=51

它没有javaOpts，但是它应该有

我希望javaOpts也存在于子任务中，如何解决它？

提前谢谢！！

Answer 1

如果要将app或deployer属性传递给子任务，则需要引用子任务的app or label名称，以便将子任务限定为子任务。

例如，在您的情况下，您需要使用如下内容：

deployer.my-composed-task.A.local.javaOpts=-Xmx8g

您可以在上面的属性引用中看到复合任务my-composed-task的名称和子任务A的名称。

有关这方面的更多信息，您可以查看文档这里。