[
https://issues.apache.org/jira/browse/FLINK-29064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-29064:
-------------------------------------
Affects Version/s: 1.15.0
(was: 1.15.1)
> 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.0
> Environment: Java 11.0.15
> OS : Ubuntu 20 or Mac OS
>
> Reporter: Evgeny Fisher
> Priority: Critical
>
> 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)
