HDFS读细节2
2022-05-05 20:58:37 2 举报读流程图②
作者其他创作
大纲/内容
最多尝试3次
DN info
根据策略创建BlockReader具体对象
通过chooseDataNode(选择一个最佳DN)
判断类型抛出异常
返回DataNodeInfo
找到
IO异常
核心方法getBlockAtoffset()获得当前block所在DN信息
blockSeekTo(long target)
更新当前读位置和block_end信息
重置DeadNode
关闭当前已有BlockReader
Yes
getBestNodeDNAddrPair
没有找到DN
while(true)一直尝试
0 条评论
下一页
为你推荐
查看更多
