我在Spring云数据流服务器中有一个合成任务,如下所示:
如果task-b
生成FAIL
形式的退出消息,则它将执行task-d
并结束流。我希望在修复问题后再次从task-b
重试此作业/合成任务,以便它可以遵循task-c
的下一个路径。作为task-a
的一部分,有一些大型处理已完成,我希望避免再次重复此任务。
当我尝试从“任务执行”选项卡启动task-b
时,它只运行了task-b
,然后停止。在“作业执行”部分,我看不到任何从task-b
重试作业/合成任务的选项。
我如何实现这一点?
1条答案
按热度按时间ukdjmx9f1#
@adesai谢谢您的提问。在您提出的方案中,此合成任务运行程序启动被视为成功,因为它具有
Task-b
“失败”时执行的选项,即启动Task-d
。因此,它无法重新启动。因为它是成功。一种选择是建议向组合任务运行器添加一个特性,该特性允许您指定一个逗号分隔的任务列表,任务运行器应该跳过这些任务。类似于composed-task-runner.skip-steps=task-a
的东西。如果这个特性有用的话,你可以为此打开一个数据流的问题。