Hi Dimitris Maybe you can use the `inputQueueLength` metric.
Best, Feng On Tue, Nov 28, 2023 at 12:07 AM Dimitris Mpanelas via user < user@flink.apache.org> wrote: > Hello, > > I am trying to determine the buffered records in the input buffers of a > task. I found the inputQueueSize metric. According to the docs it is "The > real size of queued input buffers in bytes". The docs also state that "The > size for local input channels is always 0 since the local channel take > records directly from the output queue". > > What does this metric truly represent? In which cases should it be 0 and > non 0? Is there a way to determine buffered records (or at least something > similar) by using this metric? > > Dimitris. > >
