使用参数调度组合任务

Question

我在 Spring Cloud Dataflow 中定义了这两个任务，为了简单起见，我将它们简单地称为 first-task 和 second-task。然后我定义了一个组合任务：

task create --name my-composed-task --definition "first-task && second-task"

现在，我需要安排这个任务，但我需要安排的任务以两个参数开始，假设这些参数是OBJECT_TYPES=1 和SKIP_EXTRA_STUFF=true。所以我尝试设置我的日程安排：

task schedule create --definitionName my-composed-task --name my-scheduled-task --expression '0 5 4 * ?' --arguments 'OBJECT_TYPES=1 SKIP_EXTRA_STUFF=true'

但是当计划开始时，第二个任务会失败，因为这些参数是强制性的。我还尝试像这样更改计划定义：

task schedule create --definitionName my-composed-task --name my-scheduled-task --expression '0 5 4 * ?' --arguments "--composed-task-arguments='OBJECT_TYPES=1 SKIP_EXTRA_STUFF=true'"

但参数仍然没有跨子任务传递。谁能告诉我这些定义有什么问题？

Answer 1

对于组合任务，您可以使用属性键 --composedTaskArguments 将参数传递给子任务。例如，

你可以这样做：

task schedule create --definitionName my-composed-task --name my-scheduled-task --expression '0 5 4 * ?' --arguments "--composedTaskArguments=\"OBJECT_TYPES=1 SKIP_EXTRA_STUFF=true\""

另外，请注意--composedTaskArguments 指定的值将传递给所有子任务。将参数传递给组合任务has just been added 的特定子任务的能力也传递给 SCDF。