com.dtstack.flinkx.metrics.CustomPrometheusReporter
- Lingua principale
- Java
- Stelle
- 4.1k
- Fork
- 1.7k
- Metriche di merge delle PR
- Nessuna PR unita negli ultimi 30g
Descrizione
你好,想问下,yarnper模式,CustomPrometheusReporter这个类调前我加了一些日志,jobmanager中没有找到相关日志,我在怀疑这个类是不是没用到啊,
flink-conf.yml中配置:metrics.reporter.promgateway.class: com.dtstack.flinkx.metrics.CustomPrometheusReporter
新增日志:com.dtstack.flinkx.inputformat.BaseRichInputFormat
private void initPrometheusReporter() {
LOG.info("initPrometheusReporter:" + "aaaaaaaaaaaaaaaaa");
if (useCustomPrometheusReporter()) {
Guida per i contributori
Apri la guida per i contributori
Direzione di ricerca
Inizia tracciando l’uso di CustomPrometheusReporter nella modalità YARN-per a partire dall’impostazione in flink-conf.yml, quindi esamina BaseRichInputFormat.initPrometheusReporter e confronta il relativo logging con i log di JobManager. Il lavoro è completato quando viene determinato se il reporter viene inizializzato in questa modalità e viene documentato il comportamento pertinente di configurazione o inizializzazione.
Scritto dal modello di indicizzazione a partire dal testo della issue.
Valutazione
- Stack tecnologico
- java
- Ambito
- observability
- Tipo di issue
- Bug
- Difficoltà
- 3/5
- Tempo stimato
- 1-2 giorni
- Stato di attività
- Ferma
- Chiarezza
- Da chiarire
- Idoneità per principianti
- 25/100