You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Mate Czagany (Jira)" <ji...@apache.org> on 2025/03/25 09:35:00 UTC
[jira] [Created] (FLINK-37556) OpenTelemetry reporter does not package all required classes
Mate Czagany created FLINK-37556:
------------------------------------
Summary: OpenTelemetry reporter does not package all required classes
Key: FLINK-37556
URL: https://issues.apache.org/jira/browse/FLINK-37556
Project: Flink
Issue Type: Bug
Components: Runtime / Metrics
Affects Versions: 2.0.0, 2.0.1
Reporter: Mate Czagany
To feed metrics/trace data to OpenTelemetry, metrics-otel library needs some packages which are not packaged by default resulting in ClassNotFoundExceptions, e.g.:
{code:java}
Caused by: java.lang.ClassNotFoundException: io.opentelemetry.sdk.metrics.internal.export.MetricProducer {code}
It's easily reproduced using 1.11 Flink Kubernetes Operator:
{code:java}
apiVersion: flink.apache.org/v1beta1
kind: FlinkDeployment
metadata:
name: basic-example
spec:
image: flink:2.0
flinkVersion: v2_0
flinkConfiguration:
taskmanager.numberOfTaskSlots: "2" traces.reporters: otel
traces.reporter.otel.factory.class: org.apache.flink.traces.otel.OpenTelemetryTraceReporterFactory
traces.reporter.otel.exporter.endpoint: http://my-opentelemetry-collector:4317
traces.reporter.otel.scope.variables.additional: region:eu-west-1,environment:local,flink_runtime:1.20.0 metrics.reporters: otel
metrics.reporter.otel.factory.class: org.apache.flink.metrics.otel.OpenTelemetryMetricReporterFactory
metrics.reporter.otel.exporter.endpoint: http://my-opentelemetry-collector:4317 serviceAccount: flink
jobManager:
resource:
memory: "2048m"
cpu: 1
taskManager:
resource:
memory: "2048m"
cpu: 1
job:
jarURI: local:///opt/flink/examples/streaming/StateMachineExample.jar
parallelism: 2
upgradeMode: stateless {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)