- ResponseProcessor如何处理datanode侧发过来的packet ack的
- 客户端侧backoff逻辑。
ResponseProcessor:主要功能是处理来自datanode的响应。当一个packet的响应到达时,会把这个packet从ackQueue里移除。
@Override
public void run() {
// 设置 ResponseProcessor 线程的名字
setName("ResponseProcessor for block " + block);
// new一个PipelineAck对象