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 [2]: https://i.stack.imgur.com/nlBoS.png
