HDFS-16793. Revert some partial logic of HDFS-6634
This commit is contained in:
parent
a708ff96f1
commit
dade7665fe
|
@ -241,15 +241,6 @@ public class FileJournalManager implements JournalManager {
|
||||||
if (elf.hasCorruptHeader() || (!inProgressOk && elf.isInProgress())) {
|
if (elf.hasCorruptHeader() || (!inProgressOk && elf.isInProgress())) {
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
if (elf.isInProgress()) {
|
|
||||||
try {
|
|
||||||
elf.scanLog(getLastReadableTxId(), true);
|
|
||||||
} catch (IOException e) {
|
|
||||||
LOG.error("got IOException while trying to validate header of " +
|
|
||||||
elf + ". Skipping.", e);
|
|
||||||
continue;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
if (elf.getFirstTxId() >= firstTxId) {
|
if (elf.getFirstTxId() >= firstTxId) {
|
||||||
ret.add(new RemoteEditLog(elf.firstTxId, elf.lastTxId,
|
ret.add(new RemoteEditLog(elf.firstTxId, elf.lastTxId,
|
||||||
elf.isInProgress()));
|
elf.isInProgress()));
|
||||||
|
|
Loading…
Reference in New Issue