|
@@ -167,9 +167,8 @@ public class BlockRecoveryWorker {
|
|
|
return;
|
|
|
} catch (IOException e) {
|
|
|
++errorCount;
|
|
|
- InterDatanodeProtocol.LOG.warn(
|
|
|
- "Failed to obtain replica info for block (=" + block
|
|
|
- + ") from datanode (=" + id + ")", e);
|
|
|
+ InterDatanodeProtocol.LOG.warn("Failed to recover block (block="
|
|
|
+ + block + ", datanode=" + id + ")", e);
|
|
|
}
|
|
|
}
|
|
|
|
|
@@ -429,9 +428,8 @@ public class BlockRecoveryWorker {
|
|
|
+ rBlock.getNewGenerationStamp() + " is aborted.", ripE);
|
|
|
return;
|
|
|
} catch (IOException e) {
|
|
|
- InterDatanodeProtocol.LOG.warn(
|
|
|
- "Failed to obtain replica info for block (=" + block
|
|
|
- + ") from datanode (=" + id + ")", e);
|
|
|
+ InterDatanodeProtocol.LOG.warn("Failed to recover block (block="
|
|
|
+ + block + ", datanode=" + id + ")", e);
|
|
|
}
|
|
|
}
|
|
|
checkLocations(syncBlocks.size());
|