Hi, That's how we used the executor. I think the problem is that the web requests took too long time to complete (3-4 seconds) because the requests are using a proxy server. I also transformed the asyncDataStream using a flatMap and same issue (no successfull checkpoint). If I used a simple web page without the proxy server and the checkpointing works.
Alex > -- ComplyAdvantage is a trading name of IVXS TECHNOLOGY ROMANIA. This message, including any attachments, is intended only for the use of the individual(s) to whom it is addressed and may contain information that is strictly privileged/confidential. Any other distribution, copying or disclosure is strictly prohibited. If you are not the intended recipient or have received this message in error, please notify the sender immediately by reply email and permanently delete this message including any attachments, without reading it or making a copy. Contact us <https://complyadvantage.com/contact/>. Website <https://complyadvantage.com/>.
