check epoch epoch

Signed-off-by: bufferflies <1045931706@qq.com>
tikv · Jul 4, 2023 · 5f8f377 · 5f8f377
1 parent a6e8c36
commit 5f8f377
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 5 deletions.
diff --git a/components/engine_traits/src/flush.rs b/components/engine_traits/src/flush.rs
@@ -62,7 +62,7 @@ struct FlushProgress {
 /// if the flushed index greater than it .
 #[derive(Debug, Clone)]
 pub struct SstApplyState {
-    // Map from sst meta to the apply index, <(cf_index)> --> [SstApplyEntry].
+    // Map from cf to SstApplyEntry.
     sst_map: Arc<RwLock<HashMap<usize, Vec<SstApplyEntry>>>>,
 }
 
@@ -302,9 +302,7 @@ impl<R: RaftEngine> StateStorage for R {
 #[cfg(test)]
 mod test {
     use std::vec;
-
     use kvproto::import_sstpb::SstMeta;
-
     use super::SstApplyState;
 
     #[test]

diff --git a/components/raftstore-v2/src/raft/storage.rs b/components/raftstore-v2/src/raft/storage.rs
@@ -135,7 +135,9 @@ impl<EK: KvEngine, ER> Storage<EK, ER> {
 
     #[inline]
     pub fn set_flushed_epoch(&mut self, epoch: RegionEpoch) {
-        self.flushed_epoch = epoch;
+        if util::is_epoch_stale(&self.flushed_epoch,&epoch){
+            self.flushed_epoch = epoch;
+        }
     }
 
     #[inline]

diff --git a/tests/failpoints/cases/test_unsafe_recovery.rs b/tests/failpoints/cases/test_unsafe_recovery.rs
@@ -95,7 +95,6 @@ fn test_unsafe_recovery_execution_result_report() {
         pdpb::CheckPolicy::Usekey,
         vec![b"random_key1".to_vec()],
     );
-
     let region1 = pd_client.get_region(b"random_key".as_ref()).unwrap();
     let region2 = pd_client.get_region(b"random_key1".as_ref()).unwrap();
     let region1_store0_peer = find_peer(&region1, nodes[0]).unwrap().to_owned();