Hi everyone, i'm looking for some tips with the Async IO retry strategy, the documentation isn't clear and there isn't many examples that I can find about it in the internet. I want to do some work async and retry 3 times at max, if at the 3th time it fails again just ignore the exception and move on without restarting the job. Does any one has an example on how to do this, is it even possible? It feels like the

RichAsyncFunction

is missing an onError method.

I don’t think it’s possible to move on. Not being able to execute the desired behavior is reason for Flink to fail

But shouldn't it be able to timeout? If I create a retry strategy that lasts longer the the operator timeout it should invoke the timeout method, right?

I don’t think so