小红花·文摘
  • 首页
  • 广场
  • 排行榜🏆
  • 直播
  • FAQ
Dify.AI
DolphinScheduler笔记之5: 普通任务CommonTaskProcessor

本文介绍了 DolphinScheduler 中普通任务在 master 的处理过程,包括任务状态、失败重试、触发下游节点等。通过封装 BaseTaskProcessor 实现了普通任务和条件分支任务在处理流程上的统一。CommonTaskProcessor 继承自 BaseTaskProcessor,实现了任务的提交、分发和运行等过程。任务的分发通过 TaskPriorityQueueImpl 队列实现,通过线程池执行分发任务到 worker。需要考虑的问题包括状态持久化、负载均衡、网络协议、线程隔离等。

DolphinScheduler笔记之5: 普通任务CommonTaskProcessor

Ying’s Blog
Ying’s Blog · 2023-10-01T23:52:37Z
DolphinScheduler笔记之5: 普通任务CommonTaskProcessor

本文总结了DolphinScheduler中普通任务在master节点的处理过程,包括负载均衡、字段协议、网络延迟等。逻辑分支任务在master节点执行,需要考虑线程隔离、CPU占用。DolphinScheduler通过封装BaseTaskProcessor实现了这两种任务的统一处理流程。具体介绍了CommonTaskProcessor的实现,包括init、submitTask和dispatchTask等方法。总结了master节点构建DAG生成TaskInstance后,CommonTaskProcessor完成了后续分发任务的部分,需要考虑状态持久化、负载均衡、网络协议、线程隔离等。

DolphinScheduler笔记之5: 普通任务CommonTaskProcessor

Ying’s Blog
Ying’s Blog · 2023-09-09T00:52:37Z
  • <<
  • <
  • 1 (current)
  • >
  • >>
👤 个人中心
在公众号发送验证码完成验证
登录验证
在本设备完成一次验证即可继续使用

完成下面两步后,将自动完成登录并继续当前操作。

1 关注公众号
小红花技术领袖公众号二维码
小红花技术领袖
如果当前 App 无法识别二维码,请在微信搜索并关注该公众号
2 发送验证码
在公众号对话中发送下面 4 位验证码
友情链接: MOGE.AI 九胧科技 模力方舟 Gitee AI 菜鸟教程 Remio.AI DeekSeek连连 53AI 神龙海外代理IP IPIPGO全球代理IP 东波哥的博客 匡优考试在线考试系统 开源服务指南 蓝莺IM Solo 独立开发者社区 AI酷站导航 极客Fun 我爱水煮鱼 周报生成器 He3.app 简单简历 白鲸出海 T沙龙 职友集 TechParty 蟒周刊 Best AI Music Generator

小红花技术领袖俱乐部
小红花·文摘:汇聚分发优质内容
小红花技术领袖俱乐部
Copyright © 2021-
粤ICP备2022094092号-1
公众号 小红花技术领袖俱乐部公众号二维码
视频号 小红花技术领袖俱乐部视频号二维码