【问题标题】:How to create dynamic metric in Flink如何在 Flink 中创建动态指标
【发布时间】:2019-06-20 22:55:24
【问题描述】:

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

大卫

【问题讨论】:

    标签: apache-flink metrics


    【解决方案1】:

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

    对于错误报告,您可能会发现 side outputs 也很有用。

    【讨论】:

    • 谢谢大卫。是的,侧面输出绝对适合,并且可以与适当的水槽一起使用。
    猜你喜欢
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 2021-07-16
    • 1970-01-01
    • 2017-05-27
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    相关资源
    最近更新 更多