作者:夢瑤
1. 背景
Apache Flink 和 Apache Storm 是當前業(yè)界廣泛使用的兩個分布式實時計算框架。其中?Apache Storm(以下簡稱“Storm”)在美團點評實時計算業(yè)務中已有較為成熟的運用(可參考?Storm 的可靠性保證測試),有管理平臺、常用 API 和相應的文檔,大量實時作業(yè)基于 Storm 構建。而?Apache Flink(以下簡稱“Flink”)在近期倍受關注,具有高吞吐、低延遲、高可靠和精確計算等特性,對事件窗口有很好的支持,目前在美團點評實時計算業(yè)務中也已有一定應用。
為深入熟悉了解 Flink 框架,驗證其穩(wěn)定性和可靠性,評估其實時處理性能,識別該體系中的缺點,找到其性能瓶頸并進行優(yōu)化,給用戶提供最適合的實時計算引擎,我們以實踐經驗豐富的 Storm 框架作為對照,進行了一系列實驗測試 Flink 框架的性能,計算 Flink 作為確?!爸辽僖淮巍焙汀扒『靡淮巍闭Z義的實時計算框架時對資源的消耗,為實時計算平臺資源規(guī)劃、框架選擇、性能調優(yōu)等決策及 Flink 平臺的建設提出建議并提供數據支持,為后續(xù)的 SLA 建設提供一定參考。
Flink 與 Storm 兩個框架對比:
2. 測試目標
評估不同場景、不同數據壓力下 Flink 和 Storm 兩個實時計算框架目前的性能表現,獲取其詳細性能數據并找到處理性能的極限;了解不同配置對 Flink 性能影響的程度,分析各種配置的適用場景,從而得出調優(yōu)建議。
2.1 測試場景
“輸入-輸出”簡單處理場景
通過對“輸入-輸出”這樣簡單處理邏輯場景的測試,盡可能減少其它因素的干擾,反映兩個框架本身的性能。
同時測算框架處理能力的極限,處理更加復雜的邏輯的性能不會比純粹“輸入-輸出”更高。
用戶作業(yè)耗時較長的場景
如果用戶的處理邏輯較為復雜,或是訪問了數據庫等外部組件,其執(zhí)行時間會增大,作業(yè)的性能會受到影響。因此,我們測試了用戶作業(yè)耗時較長的場景下兩個框架的調度性能。
窗口統(tǒng)計場景
實時計算中常有對時間窗口或計數窗口進行統(tǒng)計的需求,例如一天中每五分鐘的訪問量,每 100 個訂單中有多少個使用了優(yōu)惠等。Flink 在窗口支持上的功能比 Storm 更加強大,API 更加完善,但是我們同時也想了解在窗口統(tǒng)計這個常用場景下兩個框架的性能。
精確計算場景(即消息投遞語義為“恰好一次”)
Storm 僅能保證“至多一次” (At Most Once) 和“至少一次” (At Least Once) 的消息投遞語義,即可能存在重復發(fā)送的情況。有很多業(yè)務場景對數據的精確性要求較高,希望消息投遞不重不漏。Flink 支持“恰好一次” (Exactly Once) 的語義,但是在限定的資源條件下,更加嚴格的精確度要求可能帶來更高的代價,從而影響性能。因此,我們測試了在不同消息投遞語義下兩個框架的性能,希望為精確計算場景的資源規(guī)劃提供數據參考。
2.2 性能指標
吞吐量(Throughput)
單位時間內由計算框架成功地傳送數據的數量,本次測試吞吐量的單位為:條/秒。反映了系統(tǒng)的負載能力,在相應的資源條件下,單位時間內系統(tǒng)能處理多少數據。吞吐量常用于資源規(guī)劃,同時也用于協(xié)助分析系統(tǒng)性能瓶頸,從而進行相應的資源調整以保證系統(tǒng)能達到用戶所要求的處理能力。假設商家每小時能做二十份午餐(吞吐量 20 份/小時),一個外賣小哥每小時只能送兩份(吞吐量 2 份/小時),這個系統(tǒng)的瓶頸就在小哥配送這個環(huán)節(jié),可以給該商家安排十個外賣小哥配送。延遲(Latency)
數據從進入系統(tǒng)到流出系統(tǒng)所用的時間,本次測試延遲的單位為:毫秒。反映了系統(tǒng)處理的實時性。金融交易分析等大量實時計算業(yè)務對延遲有較高要求,延遲越低,數據實時性越強。假設商家做一份午餐需要 5 分鐘,小哥配送需要 25 分鐘,這個流程中用戶感受到了 30 分鐘的延遲。如果更換配送方案后延遲變成了 60 分鐘,等送到了飯菜都涼了,這個新的方案就是無法接受的。3. 測試環(huán)境
為 Storm 和 Flink 分別搭建由 1 臺主節(jié)點和 2 臺從節(jié)點構成的 Standalone 集群進行本次測試。其中為了觀察 Flink 在實際生產環(huán)境中的性能,對于部分測內容也進行了 on Yarn 環(huán)境的測試。
3.1 集群參數
3.2 框架參數
4. 測試方法
4.1 測試流程
數據生產
Data Generator 按特定速率生成數據,帶上自增的 id 和 eventTime 時間戳寫入 Kafka 的一個 Topic(Topic Data)。
數據處理
Storm Task 和 Flink Task (每個測試用例不同)從 Kafka Topic Data 相同的 Offset 開始消費,并將結果及相應 inTime、outTime 時間戳分別寫入兩個 Topic(Topic Storm 和 Topic Flink)中。
指標統(tǒng)計
Metrics Collector 按 outTime 的時間窗口從這兩個 Topic 中統(tǒng)計測試指標,每五分鐘將相應的指標寫入 MySQL 表中。
Metrics Collector 按 outTime 取五分鐘的滾動時間窗口,計算五分鐘的平均吞吐(輸出數據的條數)、五分鐘內的延遲(outTime – eventTime 或 outTime – inTime)的中位數及 99 線等指標,寫入 MySQL 相應的數據表中。最后對 MySQL 表中的吞吐計算均值,延遲中位數及延遲 99 線選取中位數,繪制圖像并分析。
4.2 默認參數
Storm 和 Flink 默認均為?At Least Once?語義。Storm 開啟 ACK,ACKer 數量為 1。Flink 的 Checkpoint 時間間隔為 30 秒,默認 StateBackend 為 Memory。保證 Kafka 不是性能瓶頸,盡可能排除 Kafka 對測試結果的影響。測試延遲時數據生產速率小于數據處理能力,假設數據被寫入 Kafka 后立刻被讀取,即 eventTime 等于數據進入系統(tǒng)的時間。測試吞吐量時從 Kafka Topic 的最舊開始讀取,假設該 Topic 中的測試數據量充足。4.3 測試用例
Identity
Identity 用例主要模擬“輸入-輸出”簡單處理場景,反映兩個框架本身的性能。輸入數據為“msgId, eventTime”,其中 eventTime 視為數據生成時間。單條輸入數據約 20 B。進入作業(yè)處理流程時記錄 inTime,作業(yè)處理完成后(準備輸出時)記錄 outTime。作業(yè)從 Kafka Topic Data 中讀取數據后,在字符串末尾追加時間戳,然后直接輸出到 Kafka。輸出數據為“msgId, eventTime, inTime, outTime”。單條輸出數據約 50 B。Sleep
Sleep 用例主要模擬用戶作業(yè)耗時較長的場景,反映復雜用戶邏輯對框架差異的削弱,比較兩個框架的調度性能。輸入數據和輸出數據均與 Identity 相同。讀入數據后,等待一定時長(1 ms)后在字符串末尾追加時間戳后輸出Windowed Word Count
Windowed Word Count 用例主要模擬窗口統(tǒng)計場景,反映兩個框架在進行窗口統(tǒng)計時性能的差異。此外,還用其進行了精確計算場景的測試,反映 Flink?恰好一次投遞的性能。輸入為 JSON 格式,包含 msgId、eventTime 和一個由若干單詞組成的句子,單詞之間由空格分隔。單條輸入數據約 150 B。讀入數據后解析 JSON,然后將句子分割為相應單詞,帶 eventTime 和 inTime 時間戳發(fā)給 CountWindow 進行單詞計數,同時記錄一個窗口中最大最小的 eventTime 和 inTime,最后帶 outTime 時間戳輸出到 Kafka 相應的 Topic。Spout/Source 及 OutputBolt/Output/Sink 并發(fā)度恒為 1,增大并發(fā)度時僅增大 JSONParser、CountWindow 的并發(fā)度。由于 Storm 對 window 的支持較弱,CountWindow 使用一個 HashMap 手動實現,Flink 用了原生的 CountWindow 和相應的 Reduce 函數。5. 測試結果5.1 Identity 單線程吞吐量
5.2 Identity 單線程作業(yè)延遲
5.3 Sleep 吞吐量
5.4 Sleep 單線程作業(yè)延遲(中位數)
5.5 Windowed Word Count 單線程吞吐量

5.6 Windowed Word Count Flink At Least Once 與 Exactly Once 吞吐量對比
5.7 Windowed Word Count Storm At Least Once 與 At Most Once 吞吐量對比
5.8 Windowed Word Count 單線程作業(yè)延遲
5.9 Windowed Word Count Flink At Least Once 與 Exactly Once 延遲對比
5.10 Windowed Word Count Storm At Least Once 與 At Most Once 延遲對比
5.11 Windowed Word Count Flink 不同 StateBackends 吞吐量對比
5.12 Windowed Word Count Flink 不同 StateBackends 延遲對比
6. 結論及建議6.1 框架本身性能
由 5.1、5.5 的測試結果可以看出,Storm 單線程吞吐約為 8.7 萬條/秒,Flink 單線程吞吐可達 35 萬條/秒。Flink 吞吐約為 Storm 的 3-5 倍。由 5.2、5.8 的測試結果可以看出,Storm QPS 接近吞吐時延遲(含 Kafka 讀寫時間)中位數約 100 毫秒,99 線約 700 毫秒,Flink 中位數約 50 毫秒,99 線約 300 毫秒。Flink 在滿吞吐時的延遲約為 Storm 的一半,且隨著 QPS 逐漸增大,Flink 在延遲上的優(yōu)勢開始體現出來。綜上可得,Flink 框架本身性能優(yōu)于 Storm。6.2 復雜用戶邏輯對框架差異的削弱
對比 5.1 和 5.3、5.2 和 5.4 的測試結果可以發(fā)現,單個 Bolt Sleep 時長達到 1 毫秒時,Flink 的延遲仍低于 Storm,但吞吐優(yōu)勢已基本無法體現。因此,用戶邏輯越復雜,本身耗時越長,針對該邏輯的測試體現出來的框架的差異越小。6.3 不同消息投遞語義的差異
由 5.6、5.7、5.9、5.10 的測試結果可以看出,Flink Exactly Once 的吞吐較 At Least Once 而言下降 6.3%,延遲差異不大;Storm At Most Once 語義下的吞吐較 At Least Once 提升 16.8%,延遲稍有下降。由于 Storm 會對每條消息進行 ACK,Flink 是基于一批消息做的檢查點,不同的實現原理導致兩者在 At Least Once 語義的花費差異較大,從而影響了性能。而 Flink 實現 Exactly Once 語義僅增加了對齊操作,因此在算子并發(fā)量不大、沒有出現慢節(jié)點的情況下對 Flink 性能的影響不大。Storm At Most Once 語義下的性能仍然低于 Flink。6.4 Flink 狀態(tài)存儲后端選擇
Flink 提供了內存、文件系統(tǒng)、RocksDB 三種 StateBackends,結合 5.11、5.12 的測試結果,三者的對比如下:
6.5 推薦使用 Flink 的場景
綜合上述測試結果,以下實時計算場景建議考慮使用 Flink 框架進行計算:
要求消息投遞語義為?Exactly Once?的場景;數據量較大,要求高吞吐低延遲的場景;需要進行狀態(tài)管理或窗口統(tǒng)計的場景。7. 展望本次測試中尚有一些內容沒有進行更加深入的測試,有待后續(xù)測試補充。例如:Exactly Once 在并發(fā)量增大的時候是否吞吐會明顯下降?用戶耗時到 1ms 時框架的差異已經不再明顯(Thread.sleep() 的精度只能到毫秒),用戶耗時在什么范圍內 Flink 的優(yōu)勢依然能體現出來?本次測試僅觀察了吞吐量和延遲兩項指標,對于系統(tǒng)的可靠性、可擴展性等重要的性能指標沒有在統(tǒng)計數據層面進行關注,有待后續(xù)補充。Flink 使用 RocksDBStateBackend 時的吞吐較低,有待進一步探索和優(yōu)化。關于 Flink 的更高級 API,如 Table API & SQL 及 CEP 等,需要進一步了解和完善。8. 參考內容分布式流處理框架——功能對比和性能評估.intel-hadoop/HiBench: HiBench is a big data benchmark suite.Yahoo的流計算引擎基準測試.Extending the Yahoo! Streaming Benchmark.
- 華為海外重大突破!西班牙內政部簽署億元數據存儲訂單
- 閃存普惠,一步到位!華為商業(yè)市場極簡全閃數據中心Pro+重磅發(fā)布
- 《企業(yè)數據治理實踐白皮書》發(fā)布,啟信寶聯(lián)合六大數交所共同編制
- 業(yè)界首個!華為數據中心自動駕駛網絡通過EANTC L4自智網絡等級測評
- AI模型的耗電量驚人 下一步是建設太空數據中心?
- 為什么制造商必須協(xié)調IT和OT,才能實現智能工業(yè)的成功?
- 打造AI時代先進算力底座,鯤鵬開發(fā)者峰會2025即將開幕
- 金山辦公宣布未來五年戰(zhàn)略:重建海外基地,優(yōu)化WPS Office用戶體驗
- 是德科技攜KAI系列布局AI新時代
- 微軟全球再裁6000人:無關績效,關乎未來
免責聲明:本網站內容主要來自原創(chuàng)、合作伙伴供稿和第三方自媒體作者投稿,凡在本網站出現的信息,均僅供參考。本網站將盡力確保所提供信息的準確性及可靠性,但不保證有關資料的準確性及可靠性,讀者在使用前請進一步核實,并對任何自主決定的行為負責。本網站對有關資料所引致的錯誤、不確或遺漏,概不負任何法律責任。任何單位或個人認為本網站中的網頁或鏈接內容可能涉嫌侵犯其知識產權或存在不實內容時,應及時向本網站提出書面權利通知或不實情況說明,并提供身份證明、權屬證明及詳細侵權或不實情況證明。本網站在收到上述法律文件后,將會依法盡快聯(lián)系相關文章源頭核實,溝通刪除相關內容或斷開相關鏈接。