Flink1.4 用于外部数据访问的异步IO

原文来源：Flink1.4 用于外部数据访问的异步IO 1. 异步IO操作的必要性 当与外部系统交互时（例如，使用存储在数据库中数据丰富流事件），需要注意与外部系统的通信延迟并不决定流应用程序的整体工作。访问外部数据库中的数据（例如在 MapFunction 中）通常意味着同步交互：将请求发送到数据库，MapFunction 会等待直到收到响应。在许多情况下，这个等待时间占了该函数绝大部分时间。

>>阅读原文<<