Можно ли зарегистрировать metri c в Job Manager во Флинке?

Question

Я хочу предоставить нашей системе мониторинга информацию о текущей версии задания на k8s. На данный момент достаточно простого metri c, выставленного в Job Manager. Можно ли зарегистрировать такой показатель c во Flink?

Answer 1

В настоящее время невозможно зарегистрировать пользовательские метрики на JobManager. Вместо этого вы можете сделать это, чтобы зарегистрировать пользовательский показатель c в одном из ваших 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;
    }
}

Это позволит зарегистрировать показатель c version в <host>.taskmanager.<tm_id>.<job_name>.<operator_name>.0.version.