Требование. Хотите внедрить пользовательские метрики шкалы/гистограммы с определяемыми пользователем переменными/метками в приложении flink. Значения для пользовательских меток будут известны только во время выполнения. Версия Flink — 1.16
public class MyMapper extends RichMapFunction {
private transient String valueToExpose;
private MetricGroup metricGroup;
@Override
public void open(Configuration config) {
this.metricGroup = getRuntimeContext().getMetricGroup();
this.metricGroup.gauge("MyGauge", new Gauge() {
@Override
public String getValue() {
return valueToExpose;
}
});
}
@Override
public String map(String value) throws Exception {
thi.metricGroup.addGroup("test1", value)
return value;
}
}
Показатели созданы с помощью "MyGauge", но поля в показателях не отображаются.
Можете ли вы мне помочь, почему метки не видны для специальных метрик?
Не хватает какой-либо конфигурации для специальных меток?
Можете ли вы поделиться примером? для показателей Flink с пользовательскими метками.
[b]Требование[/b]. Хотите внедрить пользовательские метрики шкалы/гистограммы с определяемыми пользователем переменными/метками в приложении flink. Значения для пользовательских меток будут известны только во время выполнения. [b]Версия Flink — 1.16[/b] [list] [*]Согласно документации, мы можем использовать метод addGroup для определения переменной дефиле пользователя https://nightlies.apache.org/flink/flink-docs-release-1.16/docs/ops/metrics/#user-variables https://nightlies.apache.org/flink/flink-docs -release-1.16/docs/ops/metrics/#user-scope https://nightlies.apache.org/flink/flink-docs-release-1.16/docs/ops/metrics/#gauge [/list] [code]getRuntimeContext() .getMetricGroup() .addGroup("MYLable", "Value") [/code] [list] Я использовал приведенную ниже реализацию и пытаюсь создать thi.metricGroup.[b]addGroup[/b]("test1", значение) с динамическими значениями. [/list] [code]public class MyMapper extends RichMapFunction { private transient String valueToExpose; private MetricGroup metricGroup;
@Override public void open(Configuration config) { this.metricGroup = getRuntimeContext().getMetricGroup();
this.metricGroup.gauge("MyGauge", new Gauge() { @Override public String getValue() { return valueToExpose; } }); }
@Override public String map(String value) throws Exception {
thi.metricGroup.addGroup("test1", value)
return value; } } [/code] [list] [*]Показатели созданы с помощью "[b]MyGauge[/b]", но поля в показателях не отображаются. [/list] Можете ли вы мне помочь, почему метки не видны для специальных метрик? Не хватает какой-либо конфигурации для специальных меток? Можете ли вы поделиться примером? для показателей Flink с пользовательскими метками.
Мобильная версия