You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@flink.apache.org by rania duni <ra...@gmail.com> on 2023/09/25 07:14:50 UTC

Pending Metrics

Hello! 

Is there any metric that refers to the queued records, for each operator? 

Thanks!

Re: Pending Metrics

Posted by Feng Jin <ji...@gmail.com>.

Hi Rania

Currently, there are no similar metrics available. Only the number of
memory segments in the queue between tasks
(inputQueueLength/outputQueueLength) and the buffer occupancy ratio
(inPoolUsage/outPoolUsage) are available.

For more detailed information, please refer to:
https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/ops/metrics/#network

Best,
Feng

On Mon, Sep 25, 2023 at 8:19 PM rania duni <ra...@gmail.com> wrote:

> Hello!
>
> Is there any metric that refers to the queued records, for each operator?
>
> Thanks!
>