JasonLee created FLINK-23605:
--------------------------------
Summary: An exception was thrown when the metric was reported by
PrometheusPushGatewayReporter
Key: FLINK-23605
URL: https://issues.apache.org/jira/browse/FLINK-23605
Project: Flink
Issue Type: Bug
Components: Runtime / Metrics
Affects Versions: 1.13.1, 1.13.0, 1.12.0
Reporter: JasonLee
Fix For: 1.13.2
Exceptions are as follows
{code:java}
// code placeholder
java.lang.NoSuchMethodError:
org.apache.commons.math3.stat.descriptive.rank.Percentile.withNaNStrategy(Lorg/apache/commons/math3/stat/ranking/NaNStrategy;)Lorg/apache/commons/math3/stat/descriptive/rank/Percentile;
at
org.apache.flink.runtime.metrics.DescriptiveStatisticsHistogramStatistics$CommonMetricsSnapshot.<init>(DescriptiveStatisticsHistogramStatistics.java:96)
~[flink-dist_2.11-1.13.1.jar:1.13.1] at
org.apache.flink.runtime.metrics.DescriptiveStatisticsHistogramStatistics$CommonMetricsSnapshot.<init>(DescriptiveStatisticsHistogramStatistics.java:90)
~[flink-dist_2.11-1.13.1.jar:1.13.1] at
org.apache.flink.runtime.metrics.DescriptiveStatisticsHistogramStatistics.<init>(DescriptiveStatisticsHistogramStatistics.java:40)
~[flink-dist_2.11-1.13.1.jar:1.13.1] at
org.apache.flink.runtime.metrics.DescriptiveStatisticsHistogram.getStatistics(DescriptiveStatisticsHistogram.java:49)
~[flink-dist_2.11-1.13.1.jar:1.13.1] at
org.apache.flink.metrics.prometheus.AbstractPrometheusReporter$HistogramSummaryProxy.addSamples(AbstractPrometheusReporter.java:362)
~[?:?] at
org.apache.flink.metrics.prometheus.AbstractPrometheusReporter$HistogramSummaryProxy.collect(AbstractPrometheusReporter.java:335)
~[?:?] at
io.prometheus.client.CollectorRegistry.collectorNames(CollectorRegistry.java:100)
~[?:?] at
io.prometheus.client.CollectorRegistry.register(CollectorRegistry.java:50)
~[?:?] at io.prometheus.client.Collector.register(Collector.java:139) ~[?:?]
at io.prometheus.client.Collector.register(Collector.java:132) ~[?:?] at
org.apache.flink.metrics.prometheus.AbstractPrometheusReporter.notifyOfAddedMetric(AbstractPrometheusReporter.java:135)
~[?:?] at
org.apache.flink.runtime.metrics.MetricRegistryImpl.register(MetricRegistryImpl.java:390)
~[flink-dist_2.11-1.13.1.jar:1.13.1] at
org.apache.flink.runtime.metrics.groups.AbstractMetricGroup.addMetric(AbstractMetricGroup.java:414)
~[flink-dist_2.11-1.13.1.jar:1.13.1] at
org.apache.flink.runtime.metrics.groups.AbstractMetricGroup.histogram(AbstractMetricGroup.java:367)
~[flink-dist_2.11-1.13.1.jar:1.13.1] at
org.apache.flink.streaming.util.LatencyStats.reportLatency(LatencyStats.java:65)
~[flink-dist_2.11-1.13.1.jar:1.13.1] at
org.apache.flink.streaming.api.operators.AbstractStreamOperator.reportOrForwardLatencyMarker(AbstractStreamOperator.java:580)
~[flink-dist_2.11-1.13.1.jar:1.13.1] at
org.apache.flink.streaming.api.operators.AbstractStreamOperator.processLatencyMarker(AbstractStreamOperator.java:566)
~[flink-dist_2.11-1.13.1.jar:1.13.1] at
org.apache.flink.streaming.runtime.tasks.OneInputStreamTask$StreamTaskNetworkOutput.emitLatencyMarker(OneInputStreamTask.java:216)
~[flink-dist_2.11-1.13.1.jar:1.13.1] at
org.apache.flink.streaming.runtime.io.AbstractStreamTaskNetworkInput.processElement(AbstractStreamTaskNetworkInput.java:139)
~[flink-dist_2.11-1.13.1.jar:1.13.1] at
org.apache.flink.streaming.runtime.io.AbstractStreamTaskNetworkInput.emitNext(AbstractStreamTaskNetworkInput.java:105)
~[flink-dist_2.11-1.13.1.jar:1.13.1] at
org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:66)
~[flink-dist_2.11-1.13.1.jar:1.13.1] at
org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:423)
~[flink-dist_2.11-1.13.1.jar:1.13.1] at
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:204)
~[flink-dist_2.11-1.13.1.jar:1.13.1] at
org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:681)
~[flink-dist_2.11-1.13.1.jar:1.13.1] at
org.apache.flink.streaming.runtime.tasks.StreamTask.executeInvoke(StreamTask.java:636)
~[flink-dist_2.11-1.13.1.jar:1.13.1] at
org.apache.flink.streaming.runtime.tasks.StreamTask.runWithCleanUpOnFail(StreamTask.java:647)
~[flink-dist_2.11-1.13.1.jar:1.13.1] at
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:620)
~[flink-dist_2.11-1.13.1.jar:1.13.1] at
org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:779)
~[flink-dist_2.11-1.13.1.jar:1.13.1] at
org.apache.flink.runtime.taskmanager.Task.run(Task.java:566)
~[flink-dist_2.11-1.13.1.jar:1.13.1] at
java.lang.Thread.run(Thread.java:745) ~[?:1.8.0_111]
{code}
This looks like a JAR conflict
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
