Re: Input records rate at source tasks

2017-09-13 Thread Chesnay Schepler
Hello, the input metrics for all sources are 0. You will have to modify the relevant sources to measure the number of incoming records/bytes with a Counter, and wrap this counter in a MeterView to get the rates. Register them with Flink as described in the Metrics documentation. Choose a uni

Input records rate at source tasks

2017-09-12 Thread Luis Alves
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