in ratis-logservice/src/main/java/org/apache/ratis/logservice/impl/ArchiveHdfsLogReader.java [191:205]
private void loadNext() throws IOException {
int length;
try {
length = readLength();
} catch (EOFException e) {
currentRecord = null;
return;
}
byte[] bytes = new byte[length];
if (is.read(bytes) != length) {
throw new EOFException(
"File seems to be corrupted, Encountered EOF before reading the complete record");
}
currentRecord = bytes;
}