PartitionNotFoundException on deploying streaming job

Posted by Kamil Dziublinski on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/PartitionNotFoundException-on-deploying-streaming-job-tp12515.html

Hi guys,

When I run my streaming job I almost always have initially PartitionNotFoundException. Job fails, after that restarts and it runs ok.

I wonder what is causing that and if I can adjust some parameters to not have this initial failure.

I have flink session on yarn with 55 task managers. 4 cores and 4gb per TM.

This setup is using 77% of my yarn cluster.

Any ideas?

Thanks,

Kamil.