HDFS-10381, DataStreamer DataNode exclusion log message should be warning. (John Zhuge via Yongjun Zhang)
This commit is contained in:
parent
03788d3015
commit
16c07cc68a
@ -1518,12 +1518,12 @@ protected LocatedBlock nextBlockOutputStream() throws IOException {
|
||||
success = createBlockOutputStream(nodes, storageTypes, 0L, false);
|
||||
|
||||
if (!success) {
|
||||
LOG.info("Abandoning " + block);
|
||||
LOG.warn("Abandoning " + block);
|
||||
dfsClient.namenode.abandonBlock(block, stat.getFileId(), src,
|
||||
dfsClient.clientName);
|
||||
block = null;
|
||||
final DatanodeInfo badNode = nodes[errorState.getBadNodeIndex()];
|
||||
LOG.info("Excluding datanode " + badNode);
|
||||
LOG.warn("Excluding datanode " + badNode);
|
||||
excludedNodes.put(badNode, badNode);
|
||||
}
|
||||
} while (!success && --count >= 0);
|
||||
|
@ -107,7 +107,7 @@ protected LocatedBlock nextBlockOutputStream() throws IOException {
|
||||
if (!success) {
|
||||
block = null;
|
||||
final DatanodeInfo badNode = nodes[getErrorState().getBadNodeIndex()];
|
||||
LOG.info("Excluding datanode " + badNode);
|
||||
LOG.warn("Excluding datanode " + badNode);
|
||||
excludedNodes.put(badNode, badNode);
|
||||
throw new IOException("Unable to create new block." + this);
|
||||
}
|
||||
|
Loading…
Reference in New Issue
Block a user