check unknown epoch number during replication

rockset · Aug 22, 2023 · ed8cb20 · ed8cb20
1 parent 112d771
commit ed8cb20
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/db/db_impl/db_impl.cc b/db/db_impl/db_impl.cc
@@ -1539,8 +1539,12 @@ Status DBImpl::ApplyReplicationLogRecord(ReplicationLogRecord record,
               auto epoch_number = p.second.epoch_number;
               // advance next epoch number. next_epoch_number never goes
               // backwards
-              if (epoch_number != kUnknownEpochNumber &&
-                  (epoch_number >= next_epoch_number)) {
+              if (epoch_number == kUnknownEpochNumber) {
+                epoch_recovery_succeeded = false;
+                err_oss << "Unknown epoch number during replication";
+                break;
+              }
+              if (epoch_number >= next_epoch_number) {
                 next_epoch_number = epoch_number + 1;
               }
             }