Flink1.7.2 Dataset 並行計算源碼分析

Flink1.7.2 Dataset 並行計算源碼分析 概述 瞭解Flink處理流程(用戶程序 -> JobGrapth -> ExecutionGraph -> JobVertex -> ExecutionVertex -> 並行度 -> Task(DataSourceTask,BatchTask,DataSinkTask) 瞭解ExecutionVetex的構建，Task的構建，執行，任務之間

>>阅读原文<<