有关HDFS写流程的系列文章:
【精】彻底吃透HDFS写流程(1)–BlockConstructionStage
【精】彻底吃透HDFS写流程(2)-- Namenode侧create文件
【精】彻底吃透HDFS写流程(3)-- DataStreamer线程和输出流write方法简要分析
【精】彻底吃透HDFS写流程(4)-- 输出流DFSOutputStream#write方法分析
接前文,本节分析一下DataStreamer#run方法的逻辑。
因为run方法的代码比较长,并且里面有一些异常处理、Tracing相关的非写数据核心逻辑代码,所以我这里就不贴全代码了,直接给出总结的大致流程图。
这上面特别重要的有一个地方:构建写pipeli



