Apache Flink 是德國柏林工業(yè)大學的幾個博士生和研究生從學校開始做起來的項目，早期叫做 Stratosphere。2014 年，StratoSphere 項目中的核心成員從學校出來開發(fā)了 Flink，同時將 Flink 計算的主流方向定位為流計算，并在同年將 Flink 捐贈 Apache，后來快速孵化成為 Apache 的***項目。

阿里巴巴在 2015 年開始嘗試使用 Flink。但是阿里的業(yè)務體量非常龐大，挑戰(zhàn)也很多。彼時的 Flink 不管是規(guī)模還是穩(wěn)定性尚未經歷實踐，成熟度有待商榷。為了把這么大的業(yè)務體量支持好，我們不得不在 Flink 之上做了一系列的改進，所以阿里巴巴維護了一個內部版本的 Flink，它的名字叫做 Blink。

基于 Blink 的計算平臺于 2016 年正式上線。截至目前，阿里絕大多數的技術部門都在使用 Blink。Blink 一直在阿里內部錯綜復雜的業(yè)務場景中鍛煉成長著。對于內部用戶反饋的各種性能、資源使用率、易用性等諸多方面的問題，Blink 都做了針對性的改進。

雖然現在 Blink 在阿里內部用的最多的場景主要還是流計算，但是在批計算場景也有不少業(yè)務上線使用了。例如，搜索和推薦的算法業(yè)務平臺就同時將 Blink 用于流計算和批處理。Blink 被用來實現了流批一體化的樣本生成和特征抽取流程，能夠處理的特征數達到了數千億，而且每秒鐘能處理數億條消息。在這個場景的批處理中，我們單個作業(yè)處理的數據量已經超過 400T，并且為了節(jié)省資源，我們的批處理作業(yè)是和流計算作業(yè)以及搜索的在線引擎運行在同樣的機器上。流批一體化已經在阿里巴巴取得了極大的成功，我們希望這種成功以及阿里巴巴內部的經驗都能夠帶回給社區(qū)。

Blink 開源的背景

其實從我們選擇 Flink 的***天開始，我們就一直和社區(qū)緊密合作。過去的這幾年我們也一直在把阿里對 Flink 的改進推回社區(qū)。從 2016 年開始我們已經將流計算 SQL 的大部分功能、針對 runtime 的穩(wěn)定性和性能優(yōu)化做的若干重要設計都推回了社區(qū)。但是 Blink 本身發(fā)展迭代的速度非常快，而社區(qū)有自己的步伐，很多時候可能無法把我們的變更及時推回去。對于社區(qū)來說，一些大的功能和重構，需要達成共識后，才能被接受，這樣才能更好地保證開源項目的質量，但是同時就會導致推入的速度變得相對較慢。

經過這幾年的開發(fā)迭代，我們這邊和社區(qū)之間的差距已經變得比較大了。Blink 有一些很好的新功能，比如性能優(yōu)越的批處理功能，在社區(qū)的版本是沒有的。在過去這段時間里，我們不斷聽到有人在詢問 Blink 的各種新功能，期望 Blink 盡快開源的呼聲越來越大。我們一直在思考如何開源的問題。一種方案就是和以前一樣，繼續(xù)把各種功能和優(yōu)化分解，逐個和社區(qū)討論，慢慢地推回 Flink，但這顯然不是大家所期待的。另一個方案，就是先完整地盡可能多地把代碼開源，讓社區(qū)的開發(fā)者能夠盡快試用起來。 第二個方案很快收到社區(qū)廣大用戶的支持。因此，從 2018 年年中開始我們就開始做開源的相關準備。經過半年的努力，我們終于把大部分 Blink 的功能梳理好，開源了出來。

Blink 開源的方式

**我們把代碼貢獻出來，是為了讓大家能先嘗試一些他們感興趣的功能。Blink 永遠不會單獨成為一個獨立的開源項目來運作，它一定是 Flink 的一部分。開源后我們期望能找到辦法以最快的方式將 Blink merge 到 Flink 中去。**Blink 開源只有一個目的，就是希望 Flink 做得更好。

Apache Flink 是一個社區(qū)項目，Blink 以什么樣的形式進入 Flink 是最合適的，怎么貢獻是社區(qū)最希望的方式，我們都要和社區(qū)一起討論。在過去的一段時間內，我們在 Flink 社區(qū)征求了廣泛的意見，大家一致認為將本次開源的 Blink 代碼作為 Flink 的一個 branch 直接推回到 Apache Flink 項目中是最合適的方式。并且我們和社區(qū)也一起討論規(guī)劃出一套能夠快速 merge Blink 到 Flink master 中的方案（具體細節(jié)可以查看 Flink 社區(qū)正在討論的 FLIP32）。

我們期望這個 merge 能夠在很短的時間內完成。這樣我們之后的 Machine Learning 等其他新功能就可以直接推回到 Flink master。相信用不了多久，Flink 和 Blink 就完全合二為一了。在那之后，阿里巴巴將直接使用 Flink 用于生產，并同時協助社區(qū)一起來維護 Flink。

本次開源的 Blink 的主要功能和優(yōu)化點

本次開源的 Blink 代碼在 Flink1.5.1 版本之上，加入了大量的新功能，以及在性能和穩(wěn)定性上的各種優(yōu)化。

主要貢獻包括：阿里巴巴在流計算上積累的一些新功能和性能的優(yōu)化，一套完整的（能夠跑通全部 TPC-H/TPC-DS，能夠讀取 Hive meta 和 data）高性能 Batch SQL，以及一些以提升易用性為主的功能（包括支持更高效的 interactive programming，與 zeppelin 更緊密的結合，以及體驗和性能更佳的 Flink web）。

未來我們還將繼續(xù)給 Flink 貢獻在 AI、IoT 以及其他新領域的功能和優(yōu)化。更多的關于這一版本 Blink release 的細節(jié)，請參考 Blink 代碼根目錄下的 README.md 文檔。下面，我來分模塊介紹下 Blink 主要的新的功能和優(yōu)化點。

Runtime

為了更好地支持 batch processing，以及解決阿里巴巴大規(guī)模生產場景中遇到的各種挑戰(zhàn)，Blink 對 Runtime 架構、效率、穩(wěn)定性方面都做了大量改進。

在架構方面，首先 Blink 引入了 Pluggable Shuffle Architecture，開發(fā)者可以根據不同的計算模型或者新硬件的需要實現不同的 shuffle 策略進行適配。此外 Blink 還引入新的調度架構，容許開發(fā)者根據計算模型自身的特點定制不同調度器。為了優(yōu)化性能，Blink 可以讓算子更加靈活的 chain 在一起，避免了不必要的數據傳輸開銷。在 Pipeline Shuffle 模式中，使用了 ZeroCopy 減少了網絡層內存消耗。在 BroadCast Shuffle 模式中，Blink 優(yōu)化掉了大量的不必要的序列化和反序列化開銷。此外，Blink 提供了全新的 JM FailOver 機制，JM 發(fā)生錯誤之后，新的 JM 會重新接管整個 JOB 而不是重啟 JOB，從而大大減少了 JM FailOver 對 JOB 的影響。

***，Blink 也開發(fā)了對 Kubernetes 的支持。不同于 Standalone 模式在 Kubernetes 上的拉起方式，在基于 Flink FLIP6 的架構上基礎之上，Blink 根據 job 的資源需求動態(tài)的申請 / 釋放 Pod 來運行 TaskExecutor，實現了資源彈性，提升了資源的利用率。

SQL/TableAPI

SQL/TableAPI 架構上的重構和性能的優(yōu)化是 Blink 本次開源版本的一個重大貢獻。

首先，我們對 SQL engine 的架構做了較大的調整。提出了全新的 Query Processor（QP）， 它包括了一個優(yōu)化層（Query Optimizer）和一個算子層（Query Executor）。這樣一來，流計算和批計算的在這兩層大部分的設計工作就能做到盡可能地復用。另外，SQL 和 TableAPI 的程序最終執(zhí)行的時候將不會翻譯到 DataStream 和 DataSet 這兩個 API 上，而是直接構建到可運行的 DAG 上來，這樣就使得物理執(zhí)行算子的設計不完全依賴底層的 API，有了更大的靈活度，同時執(zhí)行代碼也能夠被靈活的 codegen 出來。

唯一的一個影響就是這個版本的 SQL 和 TableAPI 不能和 DataSet 這個 API 進行互相轉換，但仍然保留了和 DataStream API 互相轉換的能力（將 DataStream 注冊成表，或將 Table 轉成 DataStream 后繼續(xù)操作）。未來，我們計劃把 dataset 的功能慢慢都在 DataStream 和 TableAPI 上面實現。到那時 DataStream 和 SQL 以及 tableAPI 一樣，是一個可以同時描述 bounded 以及 unbounded processing 的 API。

除了架構上的重構，Blink 還在具體實現上做了較多比較大的重構。

首先，Blink 引入了二進制的數據結構 BinaryRow，極大的減少了數據存儲上的開銷以及數據在序列化和反序列化上計算的開銷。

其次，在算子的實現層面，Blink 在更廣范圍內引入了 CodeGen 技術。由于預先知道算子需要處理的數據的類型，在 QP 層內部就可以直接生成更有針對性更高效的執(zhí)行代碼。Blink 的算子會動態(tài)的申請和使用資源，能夠更好的利用資源，提升效率，更加重要的是這些算子對資源有著比較好的控制，不會發(fā)生 OutOfMemory 的問題。

此外，針對流計算場景，Blink 加入了 miniBatch 的執(zhí)行模式，在 aggregate、join 等需要和 state 頻繁交互且往往又能先做部分 reduce 的場景中，使用 miniBatch 能夠極大的減少 IO，從而成數量級的提升性能。除了上面提到的這些重要的重構和功能點，Blink 還實現了完整的 SQL DDL，帶 emit 策略的流計算 DML，若干重要的 SQL 功能，以及大量的性能優(yōu)化策略。

有了上面提到的諸多架構和實現上的重構。Blink 的 SQL／tableAPI 在功能和性能方面都取得了脫胎換骨的變化。在批計算方面，首先 Blink batch SQL 能夠完整地跑通 TPC-H 和 TPC-DS，且性能上有了極大的提升。

如上圖所示，是這次開源的 Blink 版本和 spark 2.3.1 的 TPC-DS 的 benchmark 性能對比。柱狀圖的高度代表了運行的總時間，高度越低說明性能越好?？梢钥闯?，Blink 在 TPC-DS 上和 Spark 相比有著非常明顯的性能優(yōu)勢，而且這種性能優(yōu)勢隨著數據量的增加而變得越來越大。在實際的場景這種優(yōu)勢已經超過 Spark 三倍，在流計算性能上我們也取得了類似的提升。我們線上的很多典型作業(yè)，性能是原來的 3 到 5 倍。在有數據傾斜的場景，以及若干比較有挑戰(zhàn)的 TPC-H query，流計算性能甚至得到了數十倍的提升。

除了標準的 Relational SQL API。TableAPI 在功能上是 SQL 的超集，因此在 SQL 上所有新加的功能，我們在 tableAPI 也添加了相對應的 API。除此之外，我們還在 TableAPI 上引入了一些新的功能。其中一個比較重要是 cache 功能。在批計算場景下，用戶可以根據需要來 cache 計算的中間結果，從而避免不必要的重復計算，它極大地增強了 interactive programming 體驗。我們后續(xù)會在 tableAPI 上添加更多有用的功能。其實很多新功能已經在社區(qū)展開討論并被社區(qū)接受，例如我們在 tableAPI 增加了對一整行操作的算子 map/flatMap/aggregate/flatAggregate (Flink FLIP29) 等等。

Hive 的兼容性

我們這次開源的版本實現了在元數據（meta data）和數據層將 Flink 和 Hive 對接和打通。國內外很多公司都還在用 Hive 在做自己的批處理。對于這些用戶，現在使用這次 Blink 開源的版本，就可以直接用 Flink SQL 去查詢 Hive 的數據，真正能夠做到在 Hive 引擎和 Flink 引擎之間的自由切換。

為了打通元數據，我們重構了 Flink catalog 的實現，并且增加了兩種 catalog，一個是基于內存存儲的 FlinkInMemoryCatalog，另外一個是能夠橋接 Hive metaStore 的 HiveCatalog。有了這個 HiveCatalog，Flink 作業(yè)就能讀取 Hive 的 metaData。為了打通數據，我們實現了 HiveTableSource，使得 Flink job 可以直接讀取 Hive 中普通表和分區(qū)表的數據。因此，通過這個版本，用戶可以使用 Flink SQL 讀取已有的 Hive meta 和 data，做數據處理。未來我們將在 Flink 上繼續(xù)加大對 Hive 兼容性的支持，包括支持 Hive 特有的 query，data type，和 Hive UDF 等等。

Zeppelin for Flink

為了提供更好的可視化和交互式體驗，我們做了大量的工作讓 Zeppelin 能夠更好的支持 Flink。這些改動有些是在 Flink 上的，有些是在 Zeppelin 上的。在這些改動全部推回 Flink 和 Zeppelin 社區(qū)之前，大家可以使用這個 Zeppelin image (具體細節(jié)請參考 Blink 代碼里的 docs/quickstart/zeppelin_quickstart.md) 來測試和使用這些功能。

這個用于測試的 Zeppelin 版本，首先很好地融合和集成了 Flink 的多種運行模式以及運維界面。使用文本 SQL 和 tableAPI 可以自如的查詢 Flink 的 static table 和 dynamic table。此外，針對 Flink 的流計算的特點，這一版 Zeppelin 也很好地支持了 savepoint，用戶可以在界面上暫停作業(yè)，然后再從 savepoint 恢復繼續(xù)運行作業(yè)。

在數據展示方面，除了傳統(tǒng)的數據分析界面，我們也添加了流計算的翻牌器和時間序列展示等等功能。為了方便用戶試用，我們在這一版 zeppelin 中提供 3 個 built-in 的 Flink tutorial 的例子: 一個是做 Streaming ETL 的例子, 另外兩個分別是做 Flink Batch, Flink Stream 的基礎樣例。

Flink Web

我們對 Flink Web 的易用性與性能等多個方面做了大量的改進，從資源使用、作業(yè)調優(yōu)、日志查詢等維度新增了大量功能，使得用戶可以更方便的對 Flink 作業(yè)進行運維。

在資源使用方面，新增了 Cluster、TaskManager 與 Job 三個級別的資源信息，使得資源的申請與使用情況一目了然。作業(yè)的拓撲關系及數據流向可以追溯至 Operator 級別，Vertex 增加了 InQueue，OutQueue 等多項指標，可以方便的追蹤數據的反壓、過濾及傾斜情況。TaskManager 和 JobManager 的日志功能得到大幅度加強，從 Job、Vertex、SubTask 等多個維度都可以關聯至對應日志，提供多日志文件訪問入口，以及分頁展示查詢和日志高亮功能。

另外，我們使用了較新的 Angular 7.0 對 Flink web 進行了全面重構，頁面運行性能有了一倍以上的提升。 在大數據量情況下也不會發(fā)生頁面卡死或者卡頓情況。同時對頁面的交互邏輯進行了整體優(yōu)化，絕大部分關聯信息在單個頁面就可以完成查詢和比對工作，減少了大量不必要的跳轉。

未來的規(guī)劃

Blink 邁出了全面開源的***步，接下來我們會和社區(qū)合作，盡可能以最快的方式將 Blink 的功能和性能上的優(yōu)化 merge 回 Flink。

本次的開源版本一方面貢獻了 Blink 多年在流計算的積累，另一方面又重磅推出了在批處理上的成果。接下來，我們會持續(xù)給 Flink 社區(qū)貢獻其他方面的功能。我們期望每過幾個月就能看到技術上有一個比較大的亮點貢獻到社區(qū)。下一個亮點應該是對機器學習的支持。

要把機器學習支持好，有一系列的工作要做，包括引擎的功能、性能和易用性。這里面大部分的工作我們已經開發(fā)完成，并且很多功能都已經在阿里巴巴內部服務上線了。除了技術上創(chuàng)新以及新功能之外，Flink 的易用性和外圍生態(tài)也非常重要。我們已經啟動了若干這方面的項目，包括 Python 以及 Go 等多語言支持、Flink 集群管理、Notebook 以及機器學習平臺等等。這些項目有些會成為 Flink 自身的一部分貢獻回社區(qū)，有些不是。但它們都基于 Flink，是 Flink 生態(tài)的一個很好的補充。獨立于 Flink 之外的那些項目，我們都也在認真的考慮開源出來。

總之，Blink 在開源的***天起，就已經完全 all-in 的融入了 Flink 社區(qū)，我們希望所有的開發(fā)者看到我們的誠意和決心。未來，無論是功能還是生態(tài)，我們都會在 Flink 社區(qū)加大投入，我們也將投入力量做 Flink 社區(qū)的運營，讓 Flink 真正在中國、乃至全世界大規(guī)模地使用起來。我們衷心的希望更多的人加入，一起把 Apache Flink 開源社區(qū)做的更好！