Stateful函数中的自定义度量

Question

大家好，最近开始使用Apache Flink Stateful函数。我们正在使用Flink reporter将指标放入InfluxDBhttps://ci.apache.org/projects/flink/flink-docs-master/docs/deployment/metric_reporters/有状态函数提供"；函数"；具有几个现成指标的范围https://ci.apache.org/projects/flink/flink-statefun-docs-release-2.2/deployment-and-operations/metrics.html但这还不够，还需要添加自定义度量和测量。所有的源代码似乎都无法扩展，我找不到正确的方法来实现这一点。如果有人成功完成了这项任务，请分享你的经验。

Answer 1

最近在嵌入式函数SDK的主分支中添加了添加用户定义的度量的功能。参见JIRA问题。

有了这个改变，你可以做这样的事情：

public class MyFn implements StatefulFunction {
@Override
public void invoke(Context context, Object input) {
if (isBadMessage(input)) {
context.metrics().counter("bad-message").inc();
} else {
processNormalMessage(context, input);
}
}
...
}

如果您正在使用远程功能，请让ApacheFlink用户邮件列表了解它，以便维护人员也考虑将该功能的范围扩展到远程功能！

如果你很匆忙，并且对自己构建项目感到舒适，你可以立即尝试。