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
is missing an onError method.
I think that the retry strategy is not even being invoked.
05/25/2023, 8:20 PM
I don’t think it’s possible to move on. Not being able to execute the desired behavior is reason for Flink to fail
05/25/2023, 8:23 PM
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?