我正在尝试在 SCDF 中安排组合任务的启动,但一直无法找到执行此操作的方法。
我发现最接近的是 TriggerTask 源和 tasklauncher 接收器模块。见触发任务
这种方法的问题在于它采用任务工件的 URI 并使用任务的给定属性启动新的任务定义。因此,启动组合任务,甚至是预先存在的任务定义是不可能的。
tasklauncher 不只是像通过 shell 那样启动任务有什么原因吗?这样您就可以创建任务定义,并将名称提供给 TriggerTask 源。也许这个功能已经存在,而我一直忽略它。
否则,我可以编写自己的接收器,以某种方式调用任务启动,可能通过 API。