You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Evgeny Fisher (Jira)" <ji...@apache.org> on 2022/08/22 13:50:00 UTC
[jira] [Created] (FLINK-29064) java.lang.ClassCastException thrown while reporting influxdb metrics
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)