Hi, I’m running a Flink application with multiple tasks, and I noticed that in the source task metrics, the input rate (num records in per second) always equals 0, even when it’s receiving records and processing them. I’m reading the input from a socket.
Given this, I have two questions: If I use another input source such as a Kafka, will the num records in per second still be 0 (even when processing records)? If 1. is true then, do you have any hint on how can I implement this on Flink? I’m modifying Flink 1.2 for my master thesis, and I need to have access to this value in the JobManager. Thanks, Luís Alves
