HDFS-11087. NamenodeFsck should check if the output writer is still writable. Contributed by Erik Krogen.
This commit is contained in:
parent
fb3a5085e8
commit
98d9e9c4c8
|
@ -526,7 +526,14 @@ private void collectFileSummary(String path, HdfsFileStatus file, Result res,
|
||||||
} else {
|
} else {
|
||||||
out.print('.');
|
out.print('.');
|
||||||
}
|
}
|
||||||
if (res.totalFiles % 100 == 0) { out.println(); out.flush(); }
|
if (res.totalFiles % 100 == 0) {
|
||||||
|
out.println();
|
||||||
|
// checkError here will attempt to flush the stream, or report an error
|
||||||
|
// if the stream has encountered an error or been closed by the client
|
||||||
|
if (out.checkError()) {
|
||||||
|
throw new IOException("fsck encountered an error in its output stream");
|
||||||
|
}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
private void collectBlocksSummary(String parent, HdfsFileStatus file,
|
private void collectBlocksSummary(String parent, HdfsFileStatus file,
|
||||||
|
|
Loading…
Reference in New Issue