HDFS-写入错误恢复V1.0
2022-09-13 09:57:01 3 举报
HDFS错误恢复流程-写流程
作者其他创作
大纲/内容
block5
test.txt
7. DN2执行错误恢复
4. 重发Sender建立pipeline
RPC: updateBlockForPipeline
block5file-part2
RPC: updatePipeline
3. 申请新的块时间戳
8. DN2返回结果给DN1
block1file-part1
200M
Client端:
在写第二个块时发现异常的ACK信息
replyStream
3.1 给当前block一个更大的新时间戳
DataNode1
客户端机器
part1
block1
初始化输出流和DataStreamer
DataNode3
HDFS_Client
假设DN3宕机
NameNode
DataNode2
0x00@imbajin.com
写HDFS
blockStream
9. DN1返回结果给client
128M
6. DN1发Sender给DN2
part2
0M
RPC: getAdditionalDatanode
1. 剔除异常的DN
Streamer+Response线程
5. DN1执行错误恢复
0 条评论
下一页