Hi, Leon
> Besides that, Do you know if the async timeout is actually a global
timeout? meaning it accounts for the time of each attempt call plus any
interval time in between.
Yes, the timeout is total timeout, you can see [1][2] for more detail.
[1]
https://cwiki.apache.org/confluence/pages/v
Hi Ken,
Thanks for the suggestion. Definitely a good call to just wrap the retry
inside the client code. I'll give it a try.
Besides that, Do you know if the async timeout is actually a global
timeout? meaning it accounts for the time of each attempt call plus any
interval time in between.
I incre
Hi Leon,
Normally I try to handle retrying in the client being used to call the server,
as you have more control/context.
If that’s not an option for you, then normally (un)orderedWaitWithRetry()
should work - when you say “it doesn’t seem to help much”, are you saying that
even with retry you
Hi Flink users,
We are using Flink AsyncIO to call a grpc-based service in our Flink job.
And from time to time we are experiencing Async function timeout issues,
here's the exception.
```
java.lang.Exception: Could not complete the stream element: Record @
169393916 : [B@cadc5b3.
Caused by: j
