Flink 与 StatsD 计数器指标比较

Question

关于 StatsD 的计数器，它的工作方式是您不断发布计数器的值，例如。 numOfRequests|c:1 每当应用程序收到对 StatsD 守护程序的请求时。守护程序设置了刷新间隔，当它在该期间将此计数器的聚合推送到外部后端时。此外，它还将计数器重置为 0。

试图将其映射到 Flink 计数器。

1. Flink 计数器只有 inc 和 dec 方法，因此在报告时间到来之前，应用程序可以调用 inc 或 dec 来更改计数器的值。
2. 在报告时，计数器的最新值会报告给 StatsD 守护进程，但 Flink 计数器值永远不会重置（找不到任何代码）。

所以应该将 flink 计数器作为计量值报告给 StatsD。还是 Flink 会重置计数器？

Answer 1

Flink 计数器基本上是一种计量值。计数器永远不会重置。所以numRecordsIn/numRecordsOut 或任何其他计数器指标在工作的整个生命周期中不断增加。如果您想可视化一段时间内的计数，您需要在报告方法中自己计算增量并将其发送到外部后端，或者使用外部后端解决方案功能绘制增量图。

我们使用 Datadog 并使用以下图表绘制一段时间内的增量： diff(sum:numRecordsIn{$app_name,$env}.rollup(max))