Flink 1.16 с датчиком/гистограммой. Пользовательские метрики с пользовательскими метками/переменными. ⇐ JAVA

[Anonymous]

Требование. Хотите внедрить пользовательские метрики шкалы/гистограммы с определяемыми пользователем переменными/метками в приложении flink. Значения для пользовательских меток будут известны только во время выполнения.
Версия Flink — 1.16

• Согласно документации, мы можем использовать метод addGroup для определения переменной дефиле пользователя
  https://nightlies.apache.org/flink/flin ... -variables
  https://nightlies.apache.org/flink/flink-docs -release-1.16/docs/ops/metrics/#user-scope
  https://nightlies.apache.org/flink/flin ... ics/#gauge

Код: Выделить всё

getRuntimeContext()
.getMetricGroup()
.addGroup("MYLable", "Value")

• Я использовал приведенную ниже реализацию и пытаюсь создать thi.metricGroup.addGroup("test1", значение) с динамическими значениями.

Код: Выделить всё

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 с пользовательскими метками.

Подробнее здесь: https://stackoverflow.com/questions/790 ... -variables