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
