Evgeny Fisher created FLINK-29064:
-------------------------------------
Summary: java.lang.ClassCastException thrown while reporting
influxdb metrics
Key: FLINK-29064
URL: https://issues.apache.org/jira/browse/FLINK-29064
Project: Flink
Issue Type: Bug
Components: Connectors / Kafka
Affects Versions: 1.15.1
Environment: Java 11.0.15
OS : Ubuntu 20 or Mac OS
Reporter: Evgeny Fisher
We report our own metrics to InfluxDb using Flink metric reporter extension:
[https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/deployment/metric_reporters/]
, everything is working properly, we also see flink and kafka metrics.
But if we use kafkasink ( as a side output ) we get the following
ClassCastException(s) for some kafka metrics:
13:40:30,568 WARN org.apache.flink.runtime.metrics.MetricRegistryImpl [] -
Error while reporting metrics
java.lang.ClassCastException: class java.lang.Long cannot be cast to class
java.lang.Double *(java.lang.Long and java.lang.Double* are in module java.base
of loader 'bootstrap')
at
org.apache.flink.streaming.connectors.kafka.internals.metrics.KafkaMetricMutableWrapper.getValue(KafkaMetricMutableWrapper.java:37)
~[flink-connector-kafka-1.15.0.jar:1.15.0]
at
org.apache.flink.streaming.connectors.kafka.internals.metrics.KafkaMetricMutableWrapper.getValue(KafkaMetricMutableWrapper.java:27)
~[flink-connector-kafka-1.15.0.jar:1.15.0]
at org.apache.flink.metrics.influxdb.MetricMapper.map(MetricMapper.java:36)
~[flink-metrics-influxdb-1.15.0.jar:1.15.0]
at
org.apache.flink.metrics.influxdb.InfluxdbReporter.buildReport(InfluxdbReporter.java:141)
~[flink-metrics-influxdb-1.15.0.jar:1.15.0]
at
org.apache.flink.metrics.influxdb.InfluxdbReporter.report(InfluxdbReporter.java:127)
~[flink-metrics-influxdb-1.15.0.jar:1.15.0]
at
org.apache.flink.runtime.metrics.MetricRegistryImpl$ReporterTask.run(MetricRegistryImpl.java:495)
[flink-runtime-1.15.0.jar:1.15.0]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) [?:?]
at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:305) [?:?]
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305)
[?:?]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
[?:?]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
[?:?]
at java.lang.Thread.run(Thread.java:834) [?:?]
13:06:56,838 WARN org.apache.flink.runtime.metrics.MetricRegistryImpl [] -
Error while reporting metrics
java.lang.ClassCastException: class java.lang.String cannot be cast to class
java.lang.Double *(java.lang.String and java.lang.Double* are in module
java.base of loader 'bootstrap')
at
org.apache.flink.streaming.connectors.kafka.internals.metrics.KafkaMetricMutableWrapper.getValue(KafkaMetricMutableWrapper.java:37)
~[flink-connector-kafka-1.15.0.jar:1.15.0]
at
org.apache.flink.streaming.connectors.kafka.internals.metrics.KafkaMetricMutableWrapper.getValue(KafkaMetricMutableWrapper.java:27)
~[flink-connector-kafka-1.15.0.jar:1.15.0]
at org.apache.flink.metrics.influxdb.MetricMapper.map(MetricMapper.java:36)
~[flink-metrics-influxdb-1.15.0.jar:1.15.0]
at
org.apache.flink.metrics.influxdb.InfluxdbReporter.buildReport(InfluxdbReporter.java:141)
~[flink-metrics-influxdb-1.15.0.jar:1.15.0]
at
org.apache.flink.metrics.influxdb.InfluxdbReporter.report(InfluxdbReporter.java:127)
~[flink-metrics-influxdb-1.15.0.jar:1.15.0]
at
org.apache.flink.runtime.metrics.MetricRegistryImpl$ReporterTask.run(MetricRegistryImpl.java:495)
[flink-runtime-1.15.0.jar:1.15.0]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) [?:?]
at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:305) [?:?]
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305)
[?:?]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
[?:?]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
[?:?]
at java.lang.Thread.run(Thread.java:834) [?:?]
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
