在 Datadog 中找不到 Flink 直方图指标
Can't find Flink Histogram metric in Datadog
我将 Flink 作业与 Datadog 集成在一起。在我的Flink作业中,我添加了计数器和直方图的指标,但是从Datadog这边,我只能找到计数器的指标,没有直方图。
我可以从 Flink 端看到直方图指标:
但无法从 Datadog 端找到它:
我还可以找到我为作业添加的计数器指标。
我的理解是
- 我可以在 Flink 中找到直方图指标 UI,这意味着我收集指标的代码没有问题
- 我可以在 Datadog 中找到计数器指标(来自同一个作业),这意味着我的 Flink <--> Datadog 集成没有问题。
结合 1) 和 2),我不知道如何调试它。任何想法?谢谢!
这是我创建直方图的方法
@transient private var eventTimeLagHistogram: Histogram = _
override def open(config: Configuration): Unit = {
val dropwizardHistogram: com.codahale.metrics.Histogram =
new com.codahale.metrics.Histogram(new SlidingWindowReservoir(500))
eventTimeLagHistogram = getRuntimeContext()
.getMetricGroup.addGroup("OrderItemUpdateJobTest")
.histogram("eventTimeLagHistogram", new DropwizardHistogramWrapper(dropwizardHistogram))
}
override def map(t: ObjectNode): OrderItemUpdate = {
.....
eventTimeLagHistogram.update(System.currentTimeMillis()- ItemTimestamp)
.....
}
在 Flink 1.12.3 和 1.13.0 中添加了对 datadog 指标报告器中直方图指标的支持。参见 FLINK-20533。
我将 Flink 作业与 Datadog 集成在一起。在我的Flink作业中,我添加了计数器和直方图的指标,但是从Datadog这边,我只能找到计数器的指标,没有直方图。
我可以从 Flink 端看到直方图指标:
但无法从 Datadog 端找到它:
我还可以找到我为作业添加的计数器指标。
我的理解是
- 我可以在 Flink 中找到直方图指标 UI,这意味着我收集指标的代码没有问题
- 我可以在 Datadog 中找到计数器指标(来自同一个作业),这意味着我的 Flink <--> Datadog 集成没有问题。
结合 1) 和 2),我不知道如何调试它。任何想法?谢谢!
这是我创建直方图的方法
@transient private var eventTimeLagHistogram: Histogram = _
override def open(config: Configuration): Unit = {
val dropwizardHistogram: com.codahale.metrics.Histogram =
new com.codahale.metrics.Histogram(new SlidingWindowReservoir(500))
eventTimeLagHistogram = getRuntimeContext()
.getMetricGroup.addGroup("OrderItemUpdateJobTest")
.histogram("eventTimeLagHistogram", new DropwizardHistogramWrapper(dropwizardHistogram))
}
override def map(t: ObjectNode): OrderItemUpdate = {
.....
eventTimeLagHistogram.update(System.currentTimeMillis()- ItemTimestamp)
.....
}
在 Flink 1.12.3 和 1.13.0 中添加了对 datadog 指标报告器中直方图指标的支持。参见 FLINK-20533。