[
https://issues.apache.org/jira/browse/FLINK-24941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-24941:
-----------------------------------
Labels: auto-deprioritized-major pull-request-available stale-minor (was:
auto-deprioritized-major pull-request-available)
I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] and I help
the community manage its development. I see this issues has been marked as
Minor but is unassigned and neither itself nor its Sub-Tasks have been updated
for 180 days. I have gone ahead and marked it "stale-minor". If this ticket is
still Minor, please either assign yourself or give an update. Afterwards,
please remove the label or in 7 days the issue will be deprioritized.
> Cannot report backpressure with DatadogReporter
> -----------------------------------------------
>
> Key: FLINK-24941
> URL: https://issues.apache.org/jira/browse/FLINK-24941
> Project: Flink
> Issue Type: Bug
> Components: Runtime / Metrics
> Affects Versions: 1.10.0, 1.11.0
> Reporter: Ori Popowski
> Priority: Minor
> Labels: auto-deprioritized-major, pull-request-available,
> stale-minor
>
> When using {{DatadogHttpReporter}} the log is full of these errors:
>
> {code:java}
> 2021-11-16 09:51:11,521 [Flink-MetricRegistry-thread-1] INFO
> org.apache.flink.metrics.datadog.DatadogHttpReporter - The metric
> flink.task.isBackPressured will not be reported because only number types are
> supported by this reporter. {code}
> The code shows that the reason is that {{isBackPressured}} is a Boolean and
> all Gauge values are converted to {{Number}} which results in
> {{ClassCastException}} [1].
> I understand the limitation, but:
> # This bug can be easily fixed
> # Monitoring backpressure is extremely important. Without backpressure
> monitroing there's no way of seeing backpressure history and no alerts.
> h3. Workaround
> For anyone interested, rewrite the
> {{org.apache.flink.metrics.datadog.DGauge}} to map Booleans to integers (0 =>
> false, 1 => true), and use the maven/sbt shade plugin to take your own
> version of this class into the final JAR instead the existing class from the
> flink-metrics-datadog package.
>
> [1]
> https://github.com/apache/flink/blob/release-1.11/flink-metrics/flink-metrics-datadog/src/main/java/org/apache/flink/metrics/datadog/DatadogHttpReporter.java#L184-L188
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
