You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by izual <iz...@163.com> on 2020/02/28 11:37:49 UTC

请教flink 的 Latency tracking 的问题

问下flink开启latency tracking 的问题，请求restapi的返回里：

latency.operator_id.cf155f65686cb012844f7c745ec70a3c.operator_subtask_index.0.latency_p99

这个 operator_id 怎么跟代码里的算子对上？支持自定义名字吗？

如果是纯 sql 的场景，有办法跟 metric 里的 name 对应上吗？

name: Source: KafkaTableSource(...) -> SourceConversion(...) -> Calc(...) -> SinkConversionToRow -> Sink: KafkaTableSink(...)