如何从 scdf shell 将参数传递给组合任务？

Question

我正在尝试通过 scdf shell 启动组合任务。参数未正确传递给子任务

组合任务定义：

组合任务 --graph='app1 && app2'

从 shell 启动的命令：

任务启动组合任务名称 --arguments "--name=test"

参数在组合任务 jar 中传递和执行，而不是在子任务中传递并执行失败。在使用 Web UI 时，有一个名为composed-task-arguments 的选项将参数识别为子任务的参数。

Web UI 中的组合任务定义：

composed-task --graph='app1 && app2' --composed-task-arguments ='--name=test'

--composed-task-arguments 在数据外壳中无法识别。只有 --arguments 有效。如何仅将参数从数据外壳传递给子任务？

Answer 1

Launching a Composed Task 部分明确介绍了何时需要将属性和参数从 Shell 传递给子任务的场景。

特别是要将任意参数传递给子任务，您仍然必须使用--arugments 属性，但值将通过composed-task-arguments 属性传递。这是一个例子。

创建：

dataflow:>task create composition-task --definition "t1: timestamp && t2: timestamp"

启动：

数据流：>任务启动组合任务--arguments“--composed-task-arguments=foo=one bar=two”

通过此任务启动，t1 和 t2 任务都应该在运行时收到“foo=one”和“bar=two”属性。