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