Hello , I am getting following exception related and job manager had restarted.

This is usually caused by: 1) Akka failed sending the message silently, due to problems like oversized payload or serialization failures. In that case, you should find detailed error information in the logs. 2) The recipient needs more time for responding, due to problems like slow machines or network jitters. In that case, you can try to increase akka.ask.timeout.

I tried increasing akka.framesize and akka.ask.timeout values. This resulted in following exception

<http://org.apache.flink.runtime.io|org.apache.flink.runtime.io>.network.partition.PartitionNotFoundException: Partition c188f40cdaf8401fef36bf7e6122cd32#3@d7e4ba19d49c4286666eb145f9cc4295_6c80f82e38c6db0aca2cd65eb9ddef48_3_0 not found.

How to recover the job in such cases? One way was to cancel the job and redeploy. This worked but for a stateful job this might not be helpful. Please suggest of there are any better options. Flink version : 1.17.1 Using flink k8s operator.