40亿条/秒！Flink流批一体在阿里双11首次落地的背后
隨著 11 月 11 日 12 點(diǎn)鐘聲的敲響，2020 年雙 11 的 GMV 數(shù)字定格在了 4982 億，在 Flink 實(shí)時(shí)計(jì)算技術(shù)的驅(qū)動(dòng)下全程保持了絲般順滑滾動(dòng)，基于 Flink 的阿里巴巴實(shí)時(shí)計(jì)算平臺(tái)也圓滿完成了今年雙 11 整體經(jīng)濟(jì)體的實(shí)時(shí)數(shù)據(jù)任務(wù)保障，再次平穩(wěn)度過(guò)全年大考。
除了 GMV 媒體大屏之外，Flink 還支持了諸如搜索推薦實(shí)時(shí)機(jī)器學(xué)習(xí)，廣告實(shí)時(shí)反作弊，菜鳥(niǎo)訂單狀態(tài)實(shí)時(shí)跟蹤反饋，云服務(wù)器的實(shí)時(shí)攻擊探測(cè)以及大量基礎(chǔ)設(shè)施的監(jiān)控報(bào)警等等重要業(yè)務(wù)。實(shí)時(shí)業(yè)務(wù)量和數(shù)據(jù)量每年都在大幅增長(zhǎng)，今年的實(shí)時(shí)計(jì)算峰值達(dá)到了創(chuàng)紀(jì)錄的每秒 40 億條記錄，數(shù)據(jù)體量也達(dá)到了驚人的7 TB 每秒，相當(dāng)于一秒鐘需要讀完 500 萬(wàn)本《新華字典》。
截止目前，我們的實(shí)時(shí)計(jì)算作業(yè)數(shù)達(dá)到了 35000 多個(gè)，集群總計(jì)算規(guī)模也達(dá)到了超過(guò) 150 萬(wàn)核，在中國(guó)乃至世界范圍內(nèi)都處于領(lǐng)先水平。至此，Flink 已經(jīng)支持了阿里經(jīng)濟(jì)體所有的實(shí)時(shí)計(jì)算需求，實(shí)現(xiàn)了全鏈路數(shù)據(jù)實(shí)時(shí)化，第一時(shí)間為消費(fèi)者、商家以及運(yùn)營(yíng)人員帶來(lái)了數(shù)據(jù)的價(jià)值。
但今年 Flink 技術(shù)演進(jìn)帶來(lái)的價(jià)值不僅于此，基于 Flink 的流批一體數(shù)據(jù)應(yīng)用也開(kāi)始在阿里巴巴最核心的數(shù)據(jù)業(yè)務(wù)場(chǎng)景嶄露頭角，并在穩(wěn)定性、性能和效率方面都經(jīng)受住了嚴(yán)苛的生產(chǎn)考驗(yàn)。
“流批一體”在阿里核心數(shù)據(jù)場(chǎng)景首次落地
事實(shí)上，Flink 流批一體技術(shù)很早就在阿里巴巴內(nèi)部開(kāi)始應(yīng)用了。Flink 在阿里的發(fā)展始于搜索推薦場(chǎng)景，因此搜索引擎的索引構(gòu)建以及機(jī)器學(xué)習(xí)的特征工程都已經(jīng)是基于 Flink的 批流一體架構(gòu)。今年雙11，Flink 更進(jìn)一步，利用流批一體計(jì)算能力，助力數(shù)據(jù)中臺(tái)實(shí)現(xiàn)更加精準(zhǔn)的實(shí)時(shí)離線交叉數(shù)據(jù)分析和業(yè)務(wù)決策。
阿里的數(shù)據(jù)報(bào)表分為實(shí)時(shí)和離線兩種，前者在諸如雙 11 大促場(chǎng)景下的作用尤為明顯，可以為商家、運(yùn)營(yíng)以及管理層提供各種維度的實(shí)時(shí)數(shù)據(jù)信息，并幫助其及時(shí)作出決策，提升平臺(tái)和業(yè)務(wù)效率。例如：在典型的營(yíng)銷數(shù)據(jù)實(shí)時(shí)分析場(chǎng)景，運(yùn)營(yíng)和決策層需要對(duì)比大促當(dāng)天某個(gè)時(shí)間段和歷史某個(gè)時(shí)間段的數(shù)據(jù)結(jié)果（比如大促當(dāng)天 10 點(diǎn)的成交額和昨天 10 點(diǎn)成交額的對(duì)比），從而判斷當(dāng)前營(yíng)銷的效果，以及是否需要進(jìn)行調(diào)控、如何調(diào)控等策略。
在上面這種營(yíng)銷數(shù)據(jù)分析場(chǎng)景下，實(shí)際上需要兩套數(shù)據(jù)分析結(jié)果，一套是基于批處理技術(shù)在每天晚上計(jì)算出的離線數(shù)據(jù)報(bào)表，一套是基于流處理技術(shù)算出當(dāng)天的實(shí)時(shí)數(shù)據(jù)報(bào)表，然后針對(duì)實(shí)時(shí)和歷史數(shù)據(jù)進(jìn)行對(duì)比分析，根據(jù)對(duì)比結(jié)果進(jìn)行相關(guān)決策。離線和實(shí)時(shí)報(bào)表分別是基于批和流兩種不同計(jì)算引擎產(chǎn)出，即批和流分離的架構(gòu)不僅會(huì)有兩套開(kāi)發(fā)成本，更難以解決的是數(shù)據(jù)邏輯和口徑對(duì)齊問(wèn)題，很難保證兩套技術(shù)開(kāi)發(fā)出的數(shù)據(jù)統(tǒng)計(jì)結(jié)果是一致的。因此，理想的解決方案就是利用一套流批一體的計(jì)算引擎進(jìn)行數(shù)據(jù)分析，這樣離線和實(shí)時(shí)報(bào)表將天然一致。鑒于 Flink 流批一體計(jì)算技術(shù)的不斷成熟，以及前期在搜索推薦場(chǎng)景的成功落地，今年雙 11 數(shù)據(jù)平臺(tái)開(kāi)發(fā)團(tuán)隊(duì)也展示出堅(jiān)定的信心和信任，與 Flink 實(shí)時(shí)計(jì)算團(tuán)隊(duì)并肩作戰(zhàn)，共同推動(dòng)實(shí)時(shí)計(jì)算平臺(tái)技術(shù)升級(jí)，第一次讓基于 Flink 的流批一體數(shù)據(jù)處理技術(shù)在雙 11 最核心的數(shù)據(jù)場(chǎng)景順利落地。
今年由 Flink 團(tuán)隊(duì)和數(shù)據(jù)平臺(tái)團(tuán)隊(duì)共同推動(dòng)的流批一體計(jì)算框架在雙 11 數(shù)據(jù)核心場(chǎng)景成功首秀，也得到了阿里數(shù)據(jù)中臺(tái)負(fù)責(zé)人朋新宇在業(yè)務(wù)層的認(rèn)可：流批一體在技術(shù)上，實(shí)現(xiàn)了哪怕是多個(gè)計(jì)算處理模式，也只需要撰寫(xiě)一套代碼就能兼容。在計(jì)算速度上比其他框架快1倍、查詢快4倍，給小二們搭建數(shù)據(jù)報(bào)表提升了4-10倍的速度。同時(shí)，由于"一體化"的特性，能實(shí)現(xiàn)實(shí)時(shí)與離線數(shù)據(jù)的完全一致。
除了在業(yè)務(wù)開(kāi)發(fā)效率和計(jì)算性能上的進(jìn)步，流批一體計(jì)算架構(gòu)也讓集群資源利用率得到大幅提升。阿里的 Flink 實(shí)時(shí)集群經(jīng)過(guò)最近幾年的高速擴(kuò)展，已經(jīng)達(dá)到了百萬(wàn)核 CPU 的計(jì)算規(guī)模，上面運(yùn)行著數(shù)萬(wàn)個(gè) Flink 實(shí)時(shí)計(jì)算任務(wù)。白天是實(shí)時(shí)數(shù)據(jù)業(yè)務(wù)的高峰期，晚上業(yè)務(wù)低峰期計(jì)算資源出現(xiàn)空閑，正好可以為離線批任務(wù)提供免費(fèi)的計(jì)算資源。批和流一套引擎，運(yùn)行在一套資源底座上，天然的削峰填谷，自然的混布，不僅節(jié)省了開(kāi)發(fā)成本，同時(shí)也大幅節(jié)省了運(yùn)維成本和資源成本。今年雙 11，基于 Flink 的流批一體數(shù)據(jù)業(yè)務(wù)，沒(méi)有額外申請(qǐng)任何資源，批模式全部復(fù)用 Flink 實(shí)時(shí)計(jì)算集群，集群利用率大幅提升，為業(yè)務(wù)方節(jié)省了大量的資源開(kāi)銷，高效的資源模式也為后續(xù)更多業(yè)務(wù)創(chuàng)新提供了沃土。
“流批一體”，Flink 十年磨一劍
接下來(lái)讓我們從技術(shù)角度聊一下“流批一體”大數(shù)據(jù)處理技術(shù)的發(fā)展歷程。這要從開(kāi)源大數(shù)據(jù)技術(shù)的鼻祖 Hadoop 開(kāi)始談起，10 多年前 Hadoop 作為第一代開(kāi)源大數(shù)據(jù)技術(shù)出現(xiàn)，MapReduce 作為第一代批處理技術(shù)解決了大規(guī)模數(shù)據(jù)處理問(wèn)題，Hive 的出現(xiàn)更是讓用戶可以用 SQL 的方式進(jìn)行大規(guī)模數(shù)據(jù)的計(jì)算。但隨著大數(shù)據(jù)業(yè)務(wù)場(chǎng)景的逐步發(fā)展，很多應(yīng)用都對(duì)數(shù)據(jù)實(shí)時(shí)化產(chǎn)生了越來(lái)越強(qiáng)烈的需求，例如：社交媒體，電商交易，金融風(fēng)控等行業(yè)。在這個(gè)需求背景下，Storm 作為第一代大數(shù)據(jù)流處理技術(shù)應(yīng)運(yùn)而生，Storm 在架構(gòu)上和 Hadoop / Hive 完全不同，它是完全基于消息的流式計(jì)算模型，可以在毫秒級(jí)延遲情況下并發(fā)處理海量數(shù)據(jù)，因此 Storm 彌補(bǔ)了 Hadoop MapReduce 和 Hive 在時(shí)效性上的不足。就這樣大數(shù)據(jù)計(jì)算在批和流兩個(gè)方向都有了各自不同的主流引擎，并呈現(xiàn)出涇渭分明的格局，大數(shù)據(jù)處理技術(shù)經(jīng)歷完了第一個(gè)時(shí)代。
隨后大數(shù)據(jù)處理技術(shù)來(lái)到了第二個(gè)時(shí)代， Spark 和 Flink 兩款計(jì)算引擎在新時(shí)代陸續(xù)登場(chǎng)。Spark 相對(duì)于 Hadoop 和 Hive，具備更加完善的批處理表達(dá)能力和更加優(yōu)秀的性能，這讓 Spark 社區(qū)迅速發(fā)展，并逐步超越了 老牌的 Hadoop 和 Hive，成為批處理技術(shù)領(lǐng)域的主流技術(shù)。但 Spark 并未止步于批處理技術(shù)，很快 Spark 也推出了流計(jì)算解決方案，即 Spark Streaming，并不斷進(jìn)行改進(jìn)完善。但大家都知道 Spark 的核心引擎是面向“批處理”概念的，不是一款純流式計(jì)算引擎，在時(shí)效性等問(wèn)題上無(wú)法提供極致的流批一體體驗(yàn)。但 Spark 基于一套核心引擎技術(shù)，同時(shí)實(shí)現(xiàn)流和批兩種計(jì)算語(yǔ)義的理念是非常先進(jìn)的，與其具備相同流批一體理念的還有另一款新引擎 Flink。Flink 正式亮相比 Spark 稍微晚一些，但其前身是來(lái)自德國(guó)柏林工業(yè)大學(xué) 2009 年的研究項(xiàng)目 Stratosphere，至今也有 10 年之久。Flink 的理念和目標(biāo)也是利用一套計(jì)算引擎同時(shí)支持流和批兩種計(jì)算模式，但它和 Spark 相比選擇了不同的實(shí)現(xiàn)路線。Flink 選擇了面向“流處理”的引擎架構(gòu)，并認(rèn)為“批”其實(shí)是一種“有限流”，基于流為核心的引擎實(shí)現(xiàn)流批一體更加自然，并且不會(huì)有架構(gòu)瓶頸，我們可以認(rèn)為 Flink 選擇了 ”batch on streaming“ 的架構(gòu)，不同于 Spark 選擇的 “streaming on batch” 架構(gòu)。
Flink 實(shí)現(xiàn)完善的流批一體架構(gòu)也不是一蹴而就的，在早期的 Flink 版本中，Flink的流和批無(wú)論在 API 還是在Runtime 上都還沒(méi)有達(dá)到徹底的統(tǒng)一。但從 1.9 版本開(kāi)始，Flink 開(kāi)始加速在流批一體上進(jìn)行完善和升級(jí)，Flink SQL 作為用戶使用的最主流 API，率先實(shí)現(xiàn)了流批一體語(yǔ)義，使得用戶只需學(xué)習(xí)使用一套 SQL 就可以進(jìn)行流批一體的開(kāi)發(fā)，大幅節(jié)省開(kāi)發(fā)成本。
但是 SQL 并不能解決用戶的所有需求。一些定制化程度較高，比如需要精細(xì)化的操縱狀態(tài)存儲(chǔ)的作業(yè)還是需要繼續(xù)使用 DataStream API。在常見(jiàn)的業(yè)務(wù)場(chǎng)景中，用戶寫(xiě)了一份流計(jì)算作業(yè)后，一般還會(huì)再準(zhǔn)備一個(gè)離線作業(yè)進(jìn)行歷史數(shù)據(jù)的批量回刷。但是 DataStream 雖然能很好的解決流計(jì)算場(chǎng)景的各種需求，但卻缺乏對(duì)批處理的高效支持。
因此，Flink 社區(qū)在完成 SQL 流批一體升級(jí)之后，從 1.11 版本也開(kāi)始投入大量精力對(duì) DataStream 進(jìn)行流批一體能力的完善，在 DataSteam API 上增加批處理的語(yǔ)義，同時(shí)結(jié)合流批一體 Connector 的設(shè)計(jì)，讓 DataStream API 能夠在流批融合場(chǎng)景下對(duì)接 Kafka 和 HDFS 等不同類型流批數(shù)據(jù)源。 接下來(lái)流批一體的迭代計(jì)算 API 也將被引入到 DataStream 中，進(jìn)一步解鎖一系列機(jī)器學(xué)習(xí)的場(chǎng)景。
在當(dāng)前 Flink 主版本中，不管是 SQL 還是 DataStream API，在流批一體概念上都還是流計(jì)算和批計(jì)算功能的一個(gè)結(jié)合體。用戶編寫(xiě)的代碼，需要選擇使用流的方式跑，還是批的方式跑。但有些業(yè)務(wù)場(chǎng)景已經(jīng)提出更高的要求，即流批混合的需求，并且自動(dòng)的在批和流之間自動(dòng)切換，例如：數(shù)據(jù)集成以及數(shù)據(jù)入湖場(chǎng)景，用戶的需求是先把數(shù)據(jù)庫(kù)的全量數(shù)據(jù)同步到 HDFS 或者云存儲(chǔ)上，然后再自動(dòng)實(shí)時(shí)同步 DB 中的增量數(shù)據(jù)上去，并在同步過(guò)程中進(jìn)行 流批混合的 ETL 數(shù)據(jù)處理，Flink 也將在后續(xù)繼續(xù)支持更加智能的流批融合場(chǎng)景。
Flink “流批一體”技術(shù)在阿里巴巴的發(fā)展歷程
阿里巴巴是國(guó)內(nèi)最早選擇 Flink 開(kāi)源技術(shù)的公司，在 2015 年我所在的搜索推薦團(tuán)隊(duì)希望面向未來(lái)5-10 年的發(fā)展，選擇一款新的大數(shù)據(jù)計(jì)算引擎，用來(lái)處理搜索推薦后臺(tái)海量商品和用戶數(shù)據(jù)，由于電商行業(yè)對(duì)時(shí)效性具備非常高的訴求，因此我們希望新的計(jì)算引擎既有大規(guī)模批處理能力，也具備毫秒級(jí)實(shí)時(shí)處理能力，即一款流批統(tǒng)一的引擎，當(dāng)時(shí) Spark 的生態(tài)已經(jīng)走向成熟，并且通過(guò) Spark Streaming 提供了流批一體的計(jì)算能力，而 Flink 當(dāng)時(shí)剛剛在前一年成為Apache頂級(jí)項(xiàng)目，還是一個(gè)冉冉升起的新星項(xiàng)目，當(dāng)時(shí)團(tuán)隊(duì)內(nèi)部針對(duì) Spark 和 Flink 經(jīng)過(guò)了一段時(shí)間的調(diào)研和討論，一致認(rèn)為雖然 Flink當(dāng)時(shí)生態(tài)并不成熟，但其基于流處理為核心的架構(gòu)對(duì)于流批一體的支持更加合適，因此非常迅速的做出決定，在阿里內(nèi)部基于開(kāi)源 Flink 進(jìn)行完善和優(yōu)化，搭建搜索推薦的實(shí)時(shí)計(jì)算平臺(tái)。
經(jīng)過(guò)團(tuán)隊(duì)一年的努力，基于 Flink 的搜索推薦實(shí)時(shí)計(jì)算平臺(tái)成功的支持了2016 年的搜索雙 11，保證了搜索推薦全鏈路實(shí)時(shí)化。通過(guò)在阿里最核心業(yè)務(wù)場(chǎng)景的落地證明，也讓全集團(tuán)都認(rèn)識(shí)了 Flink 實(shí)時(shí)計(jì)算引擎，并決定將全集團(tuán)實(shí)時(shí)數(shù)據(jù)業(yè)務(wù)都將遷移到 Flink 實(shí)時(shí)計(jì)算平臺(tái)上。又經(jīng)過(guò)一年的努力，Flink 在 2017 年雙 11 不負(fù)眾望，非常順利的支持了全集團(tuán)雙 11 的實(shí)時(shí)數(shù)據(jù)業(yè)務(wù)，包括 GMV 大屏等最核心的數(shù)據(jù)業(yè)務(wù)場(chǎng)景。
2018 年 Flink 開(kāi)始走向云端，阿里云上推出了基于 Flink 的實(shí)時(shí)計(jì)算產(chǎn)品，旨在為廣大中小企業(yè)提供云計(jì)算服務(wù)。飲水思源，阿里巴巴不僅希望利用 Flink 技術(shù)解決自己業(yè)務(wù)的問(wèn)題，同樣也希望能夠推動(dòng) Flink 開(kāi)源社區(qū)更快的發(fā)展，為開(kāi)源技術(shù)社區(qū)做出更多貢獻(xiàn)，因此阿里巴巴在 2019 年初收購(gòu)了 Flink 創(chuàng)始公司和團(tuán)隊(duì) Ververica，開(kāi)始投入更多資源在 Flink 生態(tài)和社區(qū)上。到了 2020 年，國(guó)內(nèi)外主流科技公司幾乎都已經(jīng)選擇了 Flink 作為其實(shí)時(shí)計(jì)算解決方案，我們看到 Flink 已經(jīng)成為大數(shù)據(jù)業(yè)界實(shí)時(shí)計(jì)算的事實(shí)標(biāo)準(zhǔn)。
接下來(lái)，Flink 社區(qū)不會(huì)停止技術(shù)創(chuàng)新，在阿里巴巴業(yè)務(wù)場(chǎng)景中流批一體技術(shù)已經(jīng)從理論走向落地。2020 年的雙 11，Flink 流批一體技術(shù)在天貓營(yíng)銷決策核心系統(tǒng)中給出了精彩的表現(xiàn)，加上之前已經(jīng)在搜索推薦中成功運(yùn)行的流批一體索引構(gòu)建以及機(jī)器學(xué)習(xí)流程，充分驗(yàn)證了5 年前我們大膽選擇 Flink 技術(shù)體系的正確性，相信未來(lái)我們將會(huì)在更多公司看到 Flink 流批一體技術(shù)的落地。
“流批一體”技術(shù)創(chuàng)新，推動(dòng) Flink 開(kāi)源社區(qū)蓬勃發(fā)展
Flink 堅(jiān)持流批一體技術(shù)創(chuàng)新之路，也自然推動(dòng) Flink 開(kāi)源社區(qū)的高速發(fā)展和生態(tài)的加速繁榮。我們欣喜的看到，隨著 Flink 在國(guó)內(nèi)更多公司的加速落地，來(lái)自中文社區(qū)力量日益龐大，已經(jīng)開(kāi)始逐漸超越國(guó)外成為主流。
首先最明顯的是用戶數(shù)量的增多，從今年 6 月份起，Flink 中文郵件列表的活躍度開(kāi)始超越英文郵件列表。隨著大量的用戶涌入 Flink 社區(qū)，也帶來(lái)了更多的優(yōu)秀代碼貢獻(xiàn)者，有效的促進(jìn)了 Flink 引擎的開(kāi)發(fā)迭代。
自 1.8.0 版本以來(lái)，Flink 每個(gè)版本的 Contributor 數(shù)量都在提升，其中大多數(shù)都是來(lái)自國(guó)內(nèi)的各大企業(yè)。毫無(wú)疑問(wèn)，來(lái)自國(guó)內(nèi)的開(kāi)發(fā)者和用戶群體，已經(jīng)逐漸成為推動(dòng) Flink 向前發(fā)展的中堅(jiān)力量。
中文社區(qū)的不斷壯大，使得 Flink 整體的活躍度和 2019 年相比有增無(wú)減。在 Apache 軟件基金會(huì) 2020 財(cái)年的報(bào)告中，Flink 蟬聯(lián)了年度最活躍項(xiàng)目（通過(guò) user+dev 郵件列表活躍度）。與此同時(shí)，在代碼 Commit 次數(shù)和 Github 主頁(yè)流量這兩項(xiàng)指標(biāo)上，Flink 均排名第二。能在 Apache 軟件基金會(huì)接近 350個(gè) 頂級(jí)項(xiàng)目中取得如此成績(jī)，著實(shí)不易。
Flink Forward Asia 2020，“流批一體”技術(shù)揭秘
Flink Forward 是由 Apache 官方授權(quán)的 Flink 技術(shù)大會(huì)， 今年 Flink Forward Asia (簡(jiǎn)稱：FFA) 大會(huì)全程采用在線直播的方式，免費(fèi)為廣大開(kāi)發(fā)者提供一場(chǎng)開(kāi)源大數(shù)據(jù)技術(shù)盛宴，足不出戶可以在線觀看來(lái)自 阿里巴巴、螞蟻科技、騰訊、字節(jié)跳動(dòng)、美團(tuán)、小米、快手、B 站、網(wǎng)易、微博、Intel、DellEMC、Linkedin 等國(guó)內(nèi)外一線互聯(lián)網(wǎng)公司針對(duì) Flink 的技術(shù)實(shí)踐分享和技術(shù)創(chuàng)新。
流批一體也將是本屆 FFA 大會(huì)的熱門(mén)話題，來(lái)自天貓數(shù)據(jù)技術(shù)負(fù)責(zé)人將會(huì)給大家分享 Flink 流批一體技術(shù)在阿里的實(shí)踐和落地，讓大家看到流批一體技術(shù)是如何在雙 11 最核心的場(chǎng)景中發(fā)揮業(yè)務(wù)價(jià)值；來(lái)自阿里巴巴、字節(jié)跳動(dòng)的 Flink PMC 和 Committer 技術(shù)專家將圍繞 Flink 流批一體 SQL 和 Runtime 進(jìn)行深度技術(shù)解讀，為大家?guī)?lái) Flink 社區(qū)的最新技術(shù)進(jìn)展；來(lái)自騰訊的游戲技術(shù)專家將為大家?guī)?lái) Flink 在國(guó)民游戲王者榮耀中的應(yīng)用實(shí)踐；來(lái)自美團(tuán)的實(shí)時(shí)大數(shù)據(jù)負(fù)責(zé)人將為大家介紹 Flink 如何助力生活服務(wù)場(chǎng)景實(shí)時(shí)化；來(lái)自快手大數(shù)據(jù)負(fù)責(zé)人將為大家?guī)?lái) Flink 在快手的前世今生發(fā)展歷程；來(lái)自微博的機(jī)器學(xué)習(xí)技術(shù)專家將為大家?guī)?lái)如何利用 Flink 進(jìn)行信息推薦。此外，Flink 相關(guān)的議題還涵蓋了金融、銀行、物流、汽車制造、出行等各行各業(yè)，呈現(xiàn)出百花齊放的繁榮生態(tài)景象。歡迎對(duì)開(kāi)源大數(shù)據(jù)技術(shù)有熱情的開(kāi)發(fā)者能參加本屆 Flink Forward Asia 技術(shù)大會(huì)，了解更多 Flink 社區(qū)最新技術(shù)發(fā)展和創(chuàng)新。大會(huì)官網(wǎng)：
http://flink-forward.org.cn
原文鏈接：https://developer.aliyun.com/article/778667?
版權(quán)聲明：本文內(nèi)容由阿里云實(shí)名注冊(cè)用戶自發(fā)貢獻(xiàn)，版權(quán)歸原作者所有，阿里云開(kāi)發(fā)者社區(qū)不擁有其著作權(quán)，亦不承擔(dān)相應(yīng)法律責(zé)任。具體規(guī)則請(qǐng)查看《阿里云開(kāi)發(fā)者社區(qū)用戶服務(wù)協(xié)議》和《阿里云開(kāi)發(fā)者社區(qū)知識(shí)產(chǎn)權(quán)保護(hù)指引》。如果您發(fā)現(xiàn)本社區(qū)中有涉嫌抄襲的內(nèi)容，填寫(xiě)侵權(quán)投訴表單進(jìn)行舉報(bào)，一經(jīng)查實(shí)，本社區(qū)將立刻刪除涉嫌侵權(quán)內(nèi)容。總結(jié)
以上是生活随笔為你收集整理的40亿条/秒！Flink流批一体在阿里双11首次落地的背后的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。
- 上一篇： 2019年CNCF中国云原生调查报告
- 下一篇： Hologres是如何完美支撑双11智能