Hi Pankaj, > Is there any sample code for how to read such default metrics? Is there any way to query the default metrics, such as CPU usage and Memory, without using REST API or Reporters?
What's your real requirement? Can you use code to call REST API? Why does it not match your requirements? > Additionally, how do I query Backpressure using code, or is it still only visually available via the dashboard UI? Consequently, is there any way to infer Backpressure by querying one (or more) of the Memory metrics of the TaskManager? The backpressure is related to not only memory metrics but also IO and network metrics, for more details about measure backpressure please see this blog.[1][2] [1]: https://flink.apache.org/2019/06/05/flink-network-stack.html [2]: https://flink.apache.org/2019/07/23/flink-network-stack-2.html Best, Vino Pankaj Chand <pankajchanda...@gmail.com> 于2019年12月9日周一 下午12:07写道： > Hello, > > Using Flink on Yarn, I could not understand the documentation for how to > read the default metrics via code. In particular, I want to read > throughput, i.e. CPU usage, Task/Operator's numRecordsOutPerSecond, and > Memory. > > Is there any sample code for how to read such default metrics? Is there > any way to query the default metrics, such as CPU usage and Memory, without > using REST API or Reporters? > > Additionally, how do I query Backpressure using code, or is it still only > visually available via the dashboard UI? Consequently, is there any way to > infer Backpressure by querying one (or more) of the Memory metrics of the > TaskManager? > > Thank you, > > Pankaj >
