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)
