Re: need instruction on how the Flink metric works

2017-09-19 Thread Michael Fong
I just did the same test as you had with SocketWindowWordCount, and the counter showed up all right. You should probably connect Jconsole to localhost:28781 (or whatever port you have your JMX server listened on) That's how I setup the env, perhaps there is other better ways to do it. On Wed,

Re: need instruction on how the Flink metric works

2017-09-19 Thread Jiewen Shao
Still got stuck, here are my steps (on my laptop) for example: Step1: public class MetricsTest extends RichMapFunction { private static final long serialVersionUID = 1L; private org.apache.flink.metrics.Meter meter; private Counter counter; @Override public void

Re: need instruction on how the Flink metric works

2017-09-18 Thread Michael Fong
Hi, There are several possibilities: 1. Please check if reporter is set up ( guide ) For example, I would make sure my local JMXReporter service is up and running by

Re: need instruction on how the Flink metric works

2017-09-17 Thread Jiewen Shao
Thanks, When I started jconsole, it listed com.apache.flink.runtime.jobmanager..:[port] as one of the Local Process, i was able to connect to it with insecure connection, but i was not able to locate the Counter metrics, I only saw some system metrics. On Sun, Sep 17, 2017 at 7:39 PM, Michael

Re: need instruction on how the Flink metric works

2017-09-17 Thread Michael Fong
Hi, You may enable metrics reporter to see the output of your metrics; counter in your example. There is a brief documentation regarding to metrics and reporter setup at link . The easiest approach, in my