在 Datadog 中找不到 Flink 直方图指标

Can't find Flink Histogram metric in Datadog

我将 Flink 作业与 Datadog 集成在一起。在我的Flink作业中,我添加了计数器和直方图的指标,但是从Datadog这边,我只能找到计数器的指标,没有直方图。

我可以从 Flink 端看到直方图指标:

但无法从 Datadog 端找到它:

我还可以找到我为作业添加的计数器指标。

我的理解是

  1. 我可以在 Flink 中找到直方图指标 UI,这意味着我收集指标的代码没有问题
  2. 我可以在 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