Spring Cloud Data Flow：如何从中间节点重启动/重试组合任务

针对你遇到的场景（task-b失败后走task-d，修复后想从task-b重试走task-c，跳过task-a），可以通过Spring Cloud Data Flow的Composed Task Runner (CTR) 节点级重启特性实现，具体步骤如下：

1. 确认组合任务依赖CTR #

你的组合任务必须是通过Composed Task Runner部署的（这是SCDF管理组合任务的标准组件），只有CTR管控的任务实例才支持从指定节点重启。

2. 获取目标组合任务的执行ID #

在SCDF控制台的「任务执行」标签页中，找到失败的组合任务实例（不是单个task-b的执行记录，而是包含task-a、task-b、task-d的父任务执行记录），记录它的执行ID（比如123）。

3. 使用SCDF Shell/API执行指定节点重启 #

通过SCDF Shell或者REST API，执行重启命令时指定从task-b开始，并跳过已成功执行的task-a：

SCDF Shell命令示例： #

task execution restart --id 123 --from-task task-b --skip task-a

参数说明： #

• --id：指定要重启的组合任务实例ID
• --from-task：设置从哪个任务节点开始执行
• --skip：指定要跳过的已完成任务（这里跳过task-a避免重复执行）

4. 验证执行流程 #

执行重启命令后，CTR会复用原组合任务的上下文，直接启动task-b，如果task-b执行成功，会自动触发后续的task-c节点，完全跳过task-a的执行。

关键说明 #

• 单独启动task-b无法触发后续task-c的原因：单个任务启动不携带组合任务的上下文，CTR无法识别它属于原组合任务的分支流程，因此只会执行单个任务。
• 确保task-b本身具备幂等性：重启task-b时，要保证它重复执行不会产生重复数据或异常（比如基于持久化的状态判断是否已处理）。

内容的提问来源于stack exchange，提问作者adesai