Hi Matthias,
Thanks for taking to help us with this.
You are right there were lots of task cancellations, as this exception
causes the job to get restarted, triggering cancellations.
-
Dhanesh Arole
On Tue, Mar 23, 2021 at 9:27 AM Matthias Pohl
wrote:
> Hi Danesh,
> thanks for reaching out
Hi Danesh,
thanks for reaching out to the Flink community. Checking the code, it looks
like the OutputStream is added to a CloseableRegistry before writing to it
[1].
My suspicion is - based on the exception cause - that the CloseableRegistry
got triggered while restoring the state. I tried to tra
Hello Hivemind,
We are running a stateful streaming job. Each task manager instance hosts
around ~100GB of data. During restart of task managers we encountered
following errors, because of which the job is not able to restart.
Initially we thought it might be due to failing status checks of attach
