diff --git a/fdbserver/OldTLogServer_6_0.actor.cpp b/fdbserver/OldTLogServer_6_0.actor.cpp index 192eaaaf29..9a5934b205 100644 --- a/fdbserver/OldTLogServer_6_0.actor.cpp +++ b/fdbserver/OldTLogServer_6_0.actor.cpp @@ -1157,7 +1157,7 @@ Version poppedVersion(Reference self, Tag tag) { if (tag == txsTag || tag.locality == tagLocalityTxs) { return 0; } - return self->recoveredAt; + return self->recoveredAt + 1; } return tagData->popped; } diff --git a/fdbserver/OldTLogServer_6_2.actor.cpp b/fdbserver/OldTLogServer_6_2.actor.cpp index 0fcf76d5a3..0a11df9e99 100644 --- a/fdbserver/OldTLogServer_6_2.actor.cpp +++ b/fdbserver/OldTLogServer_6_2.actor.cpp @@ -1376,7 +1376,7 @@ Version poppedVersion(Reference self, Tag tag) { if (tag == txsTag || tag.locality == tagLocalityTxs) { return 0; } - return self->recoveredAt; + return self->recoveredAt + 1; } return tagData->popped; } diff --git a/fdbserver/TLogServer.actor.cpp b/fdbserver/TLogServer.actor.cpp index df0c3a07d3..a88595e974 100644 --- a/fdbserver/TLogServer.actor.cpp +++ b/fdbserver/TLogServer.actor.cpp @@ -1503,7 +1503,7 @@ Version poppedVersion(Reference self, Tag tag) { if (tag == txsTag || tag.locality == tagLocalityTxs) { return 0; } - return self->recoveredAt; + return self->recoveredAt + 1; } return tagData->popped; }