聊聊Flink異步I/O機制的原理

在不久前的這篇文章中，提出了一種用Flink做流處理時join外部維度數據的簡單方法。但是它的適用情境畢竟有限，通用的方法則是從Flink 1.2版本引入的異步I/O（Async I/O）機制。 異步I/O專門用來解決Flink計算過程中與外部系統的交互問題。在默認情況下，算子向外部系統發出請求後即阻塞，等待結果返回才能發送下一個請求，可能會造成較大的延遲，吞吐量下降。有了異步I/O之後，就可以並

>>阅读原文<<