[
https://issues.apache.org/jira/browse/FLINK-23605?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17448906#comment-17448906
]
rerorero commented on FLINK-23605:
----------------------------------
I faced a similar issue. I found that one of the libraries my Flink application
depends on has a dependency on a different version of apache.common.math3 than
the one Flink dist jar depends on. I resolved by shading the apache.common in
my application in my case.
> 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.12.0, 1.13.0, 1.13.1
> Reporter: JasonLee
> Priority: Major
> Fix For: 1.13.4
>
>
> 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.20.1#820001)
