2.2.1.2 LocalExecutor 并发原理


文档摘要

2.2.1.2 LocalExecutor 并发原理 2.2.1.2 LocalExecutor 并发原理:当 遇上 —— 一次因线程局部存储泄漏引发的 DAG 执行阻塞真相 你有没有在 Airflow 2.6+ 的本地开发环境中,遇到过这样的诡异现象? —— DAG 正常调度,任务状态显示为 ,日志却卡在 这一行,既不报错,也不推进; —— 显示任务已运行超 30 分钟,但 却找不到对应子进程; —— 重启 Scheduler 无济于事,清空 后重跑,问题复现; —— 最终发现:只要并发数( )设为 ≥ 4,且连续触发 3 个以上含 的 DAG,就必现; —— 而把 改成 ,一切正常。 这不是玄学。


发布者: 作者: 转发
评论区 (0)
U