apache-flink - 如何在 Flink 中创建动态指标

Question

我想创建一个与错误数量相关的指标，但实际上我想添加一些上下文标签？最好的方法是什么？测量 ？如何在任务运行期间动态创建这种指标（因为 open 方法因为太早而无法使用）？提前致谢

大卫

标签： apache-flinkmetrics

Answer 1

您应该能够随时创建一个指标——在您使用它之前，只需为每个操作员实例创建一次。

对于错误报告，您可能会发现侧面输出也很有用。