RE: Re: Re: inputQueueSize metric

2023-11-29 Thread Dimitris Banelas via user
l consistently display a value of 0. > You may consider altering the partition strategy to the rebalance strategy > for testing purposes.st it. > > > Best, > Feng. > > > On Tue, Nov 28, 2023 at 2:32 AM Dimitris Banelas via user < > user@flink.apache.org> wrote: &g

RE: Re: inputQueueSize metric

2023-11-27 Thread Dimitris Banelas via user
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