read操作OnFailure处理逻辑
2021-06-22 10:14:39 0 举报
登录查看完整内容
HDFS的踢盘处理逻辑
作者其他创作
大纲/内容
调用DataNode类的checkDiskErrorAsync方法，异步检查磁盘错误。
结束onFailure流程
检查RBW、finalize、tmp目录等是否正常。
handleVolumeFailures
OnFailuer函数
由回调处理类ResultHandler的onFailure函数处理
构造ListenableFuture对象，用于执行磁盘检查，并传入回调函数，待ListenableFuture任务执行完毕后，执行回调函数
checkVolume方法
removeVolumes移除所有不健康的volume，也就是踢盘
cleanup()清理函数
Yes，检查正常
NO，抛出了DiskErrorException
返回VolumeCheckResult.HEALTHY由回调处理类ResultHandler的onSuccess函数处理
调用回调对象callback的call方法
0 条评论
回复 删除
下一页
