Hi Chesnay, Thank you for your message. My reporter interval is set to 1 second.
On Thu, 19 Aug 2021 at 19:51, Chesnay Schepler <ches...@apache.org> wrote: > What reporter interval do you have configured? > > On 19/08/2021 13:31, Jawad Tahir wrote: > > Hi, > > > > I have defined Graphite as my matrics reporter with my Flink > > (v1.13.2). My pipeline is pretty simple. It consists of one source, > > one stateful operator (simple window aggregation), and one sink > > (operations-playground, basically). I have set the parallel factor as > > 2. The graph of the pipeline is as follows: > > > > [Flink pipeline][1] > > > > The program is running well and producing the correct results. > > However, when I see the matrics, I see that source started sending the > > records way after the system has started even though my sink was > > producing correct results since the start of the job. Here is the > > [graph][2] of uptime of the job and numRecordsOut of the source. As > > far as I understood, Apache Flink sources' numRecordsOut should start > > with uptime as my sink was producing correct results since the start. > > > > > > [1]: https://i.stack.imgur.com/rZm5h.png > > <https://i.stack.imgur.com/rZm5h.png> > > [2]: https://i.stack.imgur.com/nlBoS.png > > <https://i.stack.imgur.com/nlBoS.png> > > >
