Hi all, I have a job with the following diagram: source -> Flat Map -> Filter -> Filter -> Filter -> async wait operator -> Process -> sink
The async operation sends an HTTP post (using Apache HttpAsyncClient). In case the HTTP post times out or fails, I want to retry a few times. Is using FutureUtils.retryWithDelay() acceptable in user code? I tried it with local tests and the application works as expected. However, the API requires a ScheduledExecutor. And even though I provide one I see that the code is executed on the ForkJoin common pool. I'm a bit confused as to how the threads work here, and I'm afraid to take up resources needed for Flink framework operation. Please advise.
