DTStack / DTStack/chunjun

com.dtstack.flinkx.metrics.CustomPrometheusReporter

Aperta
#635 3 commenti 0 reazioni 0 assegnatari Vedi su GitHub
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

Ricevi le nuove issue nella tua casella

Un breve riepilogo di issue GitHub adatte ai principianti.