Flink Metrics

[Brian Ramprasad]

Hi,

I am trying to profile my Flink job.  For example I want to output the results of the TaskIOMetricGroup to a log file. Does anyone know if there is a way to access this object at runtime and execute the methods to get the data from within my user code that I submit to the Flink to start a job?



Thanks
Brian R

[Zhu Zhu]

Hi Brian,

You can implement a new org.apache.flink.metrics.reporter.MetricReporter as you like and register it to flink in flink conf.

e.g.

metrics.reporters:my_reporter
metrics.reporter.my_other_reporter.class: xxx
metrics.reporter.my_other_reporter.config1: yyy
metrics.reporter.my_other_reporter.config2: zzz

Thanks,

Zhu

Brian Ramprasad <[hidden email]> 于2019年4月18日周四 下午2:37写道：

Hi,

I am trying to profile my Flink job.  For example I want to output the results of the TaskIOMetricGroup to a log file. Does anyone know if there is a way to access this object at runtime and execute the methods to get the data from within my user code that I submit to the Flink to start a job?



Thanks
Brian R