是否可以在Flink中的Job Manager上注册指标？

Question

我想向我们的监控系统公开有关当前在k8s上运行的作业版本的信息。目前，在Job Manager上公开的简单指标就足够了。可以在Flink中注册这样的指标吗？

Answer 1

目前，无法在JobManager上注册自定义指标。相反，您可以做的是在您的某个UDF中注册一个自定义指标：

new RichMapFunction<Integer, Integer>() {
    @Override
    public void open(Configuration parameters) throws Exception {
        if (getRuntimeContext().getIndexOfThisSubtask() == 0) {
            getRuntimeContext().getMetricGroup().gauge("version", (Gauge<String>) () -> MY_VERSION_STRING);
        }
    }

    @Override
    public Integer map(Integer integer) throws Exception {
        return integer;
    }
}

这将在<host>.taskmanager.<tm_id>.<job_name>.<operator_name>.0.version下注册指标version。