Flink是一款分布式的計(jì)算引擎，它可以用來(lái)做批處理，即處理靜態(tài)的數(shù)據(jù)集、歷史的數(shù)據(jù)集;也可以用來(lái)做流處理，即實(shí)時(shí)地處理一些實(shí)時(shí)數(shù)據(jù)流，實(shí)時(shí)地產(chǎn)生數(shù)據(jù)的結(jié)果;也可以用來(lái)做一些基于事件的應(yīng)用，比如說(shuō)滴滴通過(guò)Flink CEP實(shí)現(xiàn)實(shí)時(shí)監(jiān)測(cè)用戶及司機(jī)的行為流來(lái)判斷用戶或司機(jī)的行為是否正當(dāng)。

總而言之，F(xiàn)link是一個(gè)Stateful Computations Over Streams，即數(shù)據(jù)流上的有狀態(tài)的計(jì)算。這里面有兩個(gè)關(guān)鍵字，一個(gè)是Streams，F(xiàn)link認(rèn)為有界數(shù)據(jù)集是無(wú)界數(shù)據(jù)流的一種特例，所以說(shuō)有界數(shù)據(jù)集也是一種數(shù)據(jù)流，事件流也是一種數(shù)據(jù)流。Everything is streams，即Flink可以用來(lái)處理任何的數(shù)據(jù)，可以支持批處理、流處理、AI、MachineLearning等等。

《零基礎(chǔ)入門(mén):從0到1學(xué)會(huì)Apache Flink》主要介紹 Flink Runtime 的作業(yè)執(zhí)行的核心機(jī)制。首先介紹 Flink Runtime 的整體架構(gòu)以及 Job 的基本執(zhí)行流程，然后介紹在這個(gè)過(guò)程，F(xiàn)link 是怎么進(jìn)行資源管理、作業(yè)調(diào)度以及錯(cuò)誤恢復(fù)的。最后，本文還將簡(jiǎn)要介紹 Flink Runtime 層當(dāng)前正在進(jìn)行的一些工作。