https://flink.apache.org/ logo
Title
c

Carlos Santos

05/25/2023, 5:43 PM
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 think that the retry strategy is not even being invoked.
m

Martijn Visser

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
c

Carlos Santos

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?
m

Martijn Visser

05/25/2023, 8:43 PM
I don’t think so
But not sure