Apache Flink 提供了可以恢復數據流應用到一致狀態的容錯機制。確保在發生故障時，程序的每條記錄只會作用于狀態一次（exactly-once），當然也可以降級為至少一次（at-least-once）。

我們在思考流處理問題上花了很多時間，更酷的是，我們也花了很多時間幫助其他人認識流處理，以及如何在他們的組織里應用流處理來解決數據問題。

今天我們來解讀一下Flink stream里的 source 模塊。它是整個stream的入口，也是我們了解其流處理體系的入口。

這幾年大數據的飛速發展，出現了很多熱門的開源社區，其中著名的有 Hadoop、Storm，以及后來的 Spark，他們都有著各自專注的應用場景。Spark 掀開了內存計算的先河，也以內存為賭注，...

Apache Flink 是高效和分布式的通用數據處理平臺。