Flink讀取HDFS中的數據源碼分析

Flink版本:1.4.2 目的:本文主要是瞭解Flink中DataSource是如何從HDFS中讀取數據的。 梳理一下大致流程:   在JobManager處,通過提交得來的JobGraph生成ExecutionGraph時,會將JobGraph中的每個JobVertex都轉換成ExecutionJobVertex(注意ExecutionJobVertex和ExecutionVertex的區
相關文章
相關標籤/搜索