As per the docs, the `inputQueueLength` metric refers to the number of
queued input buffers, and cannot be used on its own in order to
determine buffered records.
For instance, if I know that there are 5 queued input buffers, I cannot
conclude anything regarding buffered records if the size of each queue
is not known.
On 2023/11/27 17:28:08 Feng Jin wrote:
> 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.
> >
> >
>
