当关键任务执行失败时，Apache DolphinScheduler会像智能快递员一样，按照预设策略自动安排重试。这种基于状态机的可靠机制，能有效保障分布式系统的任务容错能力。

1. 失败时自动触发重试

当任务（如Shell脚本）执行失败时，系统会立即检查两个关键配置：

1. failRetryTimes：最多重试几次（默认0次）
2. failRetryInterval：每次重试间隔几分钟

这些配置在任务创建时设定，前端表单会将其转换为JSON格式存储。

2. 智能延迟计算

系统不会立即重试，而是计算精确的延迟时间：

// 实际延迟 = 配置间隔 - (当前时间 - 任务结束时间)long remainingTime = TimeUnit.MINUTES.toMillis(delayTime)     + System.currentTimeMillis()     - taskInstance.getEndTime().getTime();

这确保无论任务何时失败，都能保持固定的重试间隔。

3. 状态机驱动重试

重试过程由状态机精确控制：

1. 失败状态：收到失败事件后，检查是否还能重试
2. 重试状态：创建新的任务实例（保持首次提交时间不变）
3. 重新执行：发布启动事件，任务重新进入调度队列

✅ 支持重试的业务节点

1. Shell脚本任务
2. SQL查询任务
3. Spark计算任务
4. 所有实际执行代码的任务 5

❌ 不支持重试的逻辑节点

1. 条件分支节点
2. 子流程节点
3. 依赖检查节点 这些节点只控制流程走向，不执行具体代码 5 。

集成测试展示了完整的重试过程：

1. 任务A首次失败（retryTimes=0）
2. 系统自动重试1次（retryTimes=1）
3. 两次任务实例保持相同的firstSubmitTime
4. 最终失败后工作流停止 6 。

依赖任务等待

如果任务B依赖任务A，当A失败但未达最大重试次数时，B会进入等待状态而非直接失败 7 。

手动干预能力

即使任务正在等待重试，你仍可以：

1. 暂停任务（取消后续重试）
2. 终止任务（强制停止） 系统会优雅地处理这些中断请求 8 。

1. 任务重试：任务代码执行失败后的自动重试
2. Worker容错 ：当Worker服务器宕机时，Master接管并重新调度任务（包括Yarn任务） 9

1. 合理设置重试间隔：避免过于频繁的重试导致系统压力
2. 区分任务类型：为关键任务设置更多重试次数
3. 监控重试指标：关注retryTimes字段，识别不稳定任务
4. 理解逻辑节点限制：不要期望条件分支会自动重试

通过智能重试策略、精确状态控制和灵活干预机制，Apache DolphinScheduler为任务执行提供了多层保障。这种设计既确保了系统可靠性，又给予开发者充分的控制权。

1. 重试间隔以分钟为单位，实际延迟计算会扣除任务已结束的时间
2. 每次重试会创建新的TaskInstance记录，但保持firstSubmitTime不变
3. Worker宕机触发的容错重试与任务失败重试是两种不同的机制
4. 逻辑节点（如子流程）不支持自动重试，需要手动干预