1

从 Airflow 2.1.4 升级到 2.2.0(或 2.2.1 或 2.2.2)后,我们有许多 DAG 无法执行。Airflow 提供的错误是“Negsignal.SIGKILL”。当使用 SequentialExecutor 在本地运行以及部署到 EKS Kubernetes 集群时,会发生这种情况。

我们似乎无法找到有关 DAG 的任何问题,它们非常简单。有些 DAG 运行良好,有些则不行。

有这样的报道吗?在这一点上,问题似乎与 Airflow 2.2.x 系列有关,因为降级到 2.1.x 可以解决问题。

任何建议将不胜感激,因为我们需要升级以修复一些其他已知问题。

[2021-12-14, 19:51:36 UTC] {local_task_job.py:154} INFO - Task exited with return code Negsignal.SIGKILL

更新 12-14

我们已将问题缩小到使用 flask-appbuilder 模块的 DAG。在一些地方,我们使用 cached_app() 方法来查询 Airflow 用户和角色以执行维护任务。Airflow 2.2.x 中似乎发生了一些变化,导致容器立即终止。

4

0 回答 0