|
@@ -755,8 +755,10 @@ public class FSImage implements Closeable {
|
|
|
prog.endPhase(Phase.LOADING_FSIMAGE);
|
|
|
|
|
|
if (!rollingRollback) {
|
|
|
+ prog.beginPhase(Phase.LOADING_EDITS);
|
|
|
long txnsAdvanced = loadEdits(editStreams, target, Long.MAX_VALUE,
|
|
|
startOpt, recovery);
|
|
|
+ prog.endPhase(Phase.LOADING_EDITS);
|
|
|
needToSave |= needsResaveBasedOnStaleCheckpoint(imageFile.getFile(),
|
|
|
txnsAdvanced);
|
|
|
} else {
|
|
@@ -888,8 +890,6 @@ public class FSImage implements Closeable {
|
|
|
StartupOption startOpt, MetaRecoveryContext recovery)
|
|
|
throws IOException {
|
|
|
LOG.debug("About to load edits:\n " + Joiner.on("\n ").join(editStreams));
|
|
|
- StartupProgress prog = NameNode.getStartupProgress();
|
|
|
- prog.beginPhase(Phase.LOADING_EDITS);
|
|
|
|
|
|
long prevLastAppliedTxId = lastAppliedTxId;
|
|
|
long remainingReadTxns = maxTxnsToRead;
|
|
@@ -928,7 +928,6 @@ public class FSImage implements Closeable {
|
|
|
} finally {
|
|
|
FSEditLog.closeAllStreams(editStreams);
|
|
|
}
|
|
|
- prog.endPhase(Phase.LOADING_EDITS);
|
|
|
return lastAppliedTxId - prevLastAppliedTxId;
|
|
|
}
|
|
|
|