|
问下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(...)
|