Hi Amir, I suggest you post actual relevant thread stacks here. We can see those in the the image, but text is better. Essentially Flink UnboundedSource reader is doing a sleep()..
On Thu, Nov 10, 2016 at 5:59 PM, amir bahmanyari <[email protected]> wrote: > I am checking the runtime state of the KafkaIO() threads using jconsole. > I see as many cores as I have specified on my server all right. > Is TIMED_WAITING the right state for them all to be in all the time? > I monitor them and that state never changes... > Is the "Total waited" time range reasonable? > Thanks+regards, > > [image: Inline image] > >
