remove redundant line
This commit is contained in:
parent
31efdf1cc2
commit
e696c4a8eb
|
@ -1579,7 +1579,6 @@ ACTOR Future<Void> masterCore( Reference<MasterData> self ) {
|
|||
BinaryWriter bw(Unversioned());
|
||||
tr.set(recoveryCommitRequest.arena, snapshotEndVersionKey, (bw << self->lastEpochEnd).toValue());
|
||||
// Clear the key so multiple recoveries will not overwrite the first version recorded
|
||||
self->txnStateStore->clear(singleKeyRange(writeRecoveryKey));
|
||||
tr.clear(recoveryCommitRequest.arena, singleKeyRange(writeRecoveryKey));
|
||||
}
|
||||
if(self->forceRecovery) {
|
||||
|
|
|
@ -118,7 +118,6 @@ struct IncrementalBackupWorkload : TestWorkload {
|
|||
state Reference<IBackupContainer> backupContainer;
|
||||
state UID backupUID;
|
||||
state Version beginVersion = invalidVersion;
|
||||
TraceEvent("IBackupRestoreAttempt");
|
||||
wait(success(self->backupAgent.waitBackup(cx, self->tag.toString(), false, &backupContainer, &backupUID)));
|
||||
if (self->checkBeginVersion) {
|
||||
TraceEvent("IBackupReadSystemKeys");
|
||||
|
@ -149,6 +148,8 @@ struct IncrementalBackupWorkload : TestWorkload {
|
|||
}
|
||||
}
|
||||
}
|
||||
TraceEvent("IBackupRestoreAttempt")
|
||||
.detail("BeginVersion", beginVersion);
|
||||
wait(
|
||||
success(self->backupAgent.restore(cx, cx, Key(self->tag.toString()), Key(backupContainer->getURL()),
|
||||
true, invalidVersion, true, normalKeys, Key(), Key(), true, true, beginVersion)));
|
||||
|
|
Loading…
Reference in New Issue