#apache-flink #apache-beam
Вопрос:
Недавно я добавлял простые показатели в свои задания Apache Beam и проверял полученные показатели (как в консоли Flink, так и в Prometheus).
Однако при добавлении такой метрики Metrics.counter("sampleNs", "sampleMetric"); результирующий результат будет таким flink_taskmanager_job_task_operator_sampleNs_sampleMetric .
Существует ли какая-либо готовая поддержка для удаления префиксов и оставления экспортированной метрики как sampleNs_sampleMetric (или любого другого более простого префикса)?
Единственным связанным с этим вопросом вопросом, близким к решению проблемы, была следующая тема списка рассылки, но, похоже, простого решения этой проблемы не существует http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Renaming-the-metrics-td36124.html.
На случай, если я захочу добиться чего-то подобного от Apache Beam… Потребуется ли для этого развить мой собственный Флинк, чтобы я мог перезаписать тот, который используется из Apache Beam, также в локальной развилке?