如何在 Flink 中创建动态指标



我想创建一个与错误数量相关的指标,但实际上我想添加一些上下文标签?最好的方法是什么?轨距?如何在任务运行期间动态创建这种指标(因为开放方法是不可能的,因为太早了(?提前致谢

大卫

您应该能够随时创建指标 - 只需在每个运算符实例中执行一次,然后再使用它。

对于错误报告,您可能会发现旁路输出也很有用。

相关内容

  • 没有找到相关文章

最新更新