Метрики Flink 1.16 с OpenTelemetry ⇐ JAVA

[Anonymous]

Требование – Хотите реализовать метрики OpenTelemetry в Java-приложении Flink
Версия Flink – 1.16

• добавил приведенную ниже зависимость в мое Java-приложение POM.

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

   
io.opentelemetry
opentelemetry-api
1.30.0



io.opentelemetry
opentelemetry-sdk
1.30.0

• Внедрить приведенные ниже показатели OTEL в мое приложение Flink

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

import io.opentelemetry.api.GlobalOpenTelemetry;
import io.opentelemetry.api.metrics.DoubleHistogram;
import io.opentelemetry.api.metrics.Meter;

public class OTELMetrics {

private DoublrHidyohtsm historgram;

Meter meter = GlobalOpenTelemetry.meterBuilfer(OTELMetrics.class.toString()).build();
historgram = meter.histogramBuilder("MY_Custom_Metrics").setUnit("ms").build();

----------
-------------

Attributes attr = Attributes.builder().put("Param1", val1).put("param2", valu2);
historgram.record(startTime, attr );

}

[*]Создайте и разверните приложение flink, но метрики не отображаются в метриках панели мониторинга flink.
< /ol>
Пара вопросов

[*]Поддерживает ли Flink 1.16 OpenTelemetry?
[*]если это объясняет, почему метрики не отображаются на панели мониторинга flink?
[*]можете ли вы поделиться рабочим кодом для flink с реализацией OpenTelemetry.


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