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.

Reply via email to