在Airflow 2.4文档中,关于"stalled_task_timeout"的"adopted tasks"指的是在任务超时之前,由Airflow调度程序(scheduler)重新分配给其他可用执行器的任务。
解决方法如下所示:
airflow.cfg
),找到并修改以下行:[scheduler]
stalled_task_timeout = 1800
将stalled_task_timeout
设置为你想要的超时时间(以秒为单位)。
在超时时间(1800秒)内,如果一个任务没有收到来自执行器的心跳信号,调度程序将认为该任务已经停滞。然后,调度程序将重新分配该任务给其他可用执行器。
通过设置适当的超时时间,可以确保任务在适当的时间内完成,并防止任务长时间停滞导致资源浪费。
请注意,此功能仅适用于Airflow 2.4及更高版本。