小编l0n*_*g3r的帖子

Airflow 1.9.0正在排队,但没有启动任务

气流随机不运行排队任务有些任务甚至没有排队状态.我在调度程序日志中一直看到以下内容

 [2018-02-28 02:24:58,780] {jobs.py:1077} INFO - No tasks to consider for execution.
Run Code Online (Sandbox Code Playgroud)

我确实看到数据库中的任务没有状态或排队状态,但它们永远不会开始.

气流设置在ECS上使用Redis 运行https://github.com/puckel/docker-airflow.有4个调度程序线程和4个Celery工作程序任务.当悬停在任务图标上时,未运行的任务显示在排队状态(灰色图标)操作符为空,任务详细信息显示:

    All dependencies are met but the task instance is not running. In most cases this just means that the task will probably be scheduled soon unless:- The scheduler is down or under heavy load
Run Code Online (Sandbox Code Playgroud)

调度程序上的度量标准不会显示负载.dag非常简单,2个独立任务仅取决于最后一次运行.同一个dag中的任务也没有状态(白色图标).

有趣的是要注意的是,当我重新启动调度程序时,任务更改为运行状态.

airflow airflow-scheduler

32
推荐指数
5
解决办法
3万
查看次数

我们如何使用nodetool来查找集群中的不平衡?

我需要知道我们是否可以使用cassandra 1.1.6提供的nodetool来查找集群中是否存在不平衡.

cassandra cql3

2
推荐指数
1
解决办法
466
查看次数

使用string属性覆盖hashCode函数

在下面的代码中,我想使用"term"属性来生成哈希码.如何使用此String属性生成哈希代码?

class Term {
    String term;
    @Override
    public boolean equals(Object o) {
        if (o instanceof Term) {
            return this.term.equals(((Term)o).term);
        }
        return false;
    }
    @Override
    public int hashCode() {
    }
}
Run Code Online (Sandbox Code Playgroud)

java string hashcode

1
推荐指数
1
解决办法
2965
查看次数

标签 统计

airflow ×1

airflow-scheduler ×1

cassandra ×1

cql3 ×1

hashcode ×1

java ×1

string ×1