dev

Author: loboxu.1227

Cargo.toml

@@ -49,6 +49,7 @@ mobc = "0.8.4"
 openraft = { git = "https://github.com/databendlabs/openraft.git", features = [
     "serde",
     "type-alias",
+    "loosen-follower-log-revert",
 ] }
 byteorder = "1.5.0"
 tracing = "0.1.40"

src/placement-center/src/openraft/error.rs

@@ -1,7 +1,7 @@
 use std::fmt::Display;
 
 use common_base::errors::RobustMQError;
-use openraft::error::{NetworkError, RPCError};
+use openraft::error::{NetworkError, RPCError, Unreachable};
 
 use super::typeconfig::TypeConfig;
 
@@ -19,5 +19,5 @@ impl std::error::Error for ErrWrap {}
 pub fn to_error<E: std::error::Error + 'static + Clone>(
     e: RobustMQError,
 ) -> RPCError<TypeConfig, E> {
-    RPCError::Network(NetworkError::new(&e))
+    RPCError::Unreachable(Unreachable::new(&e))
 }

src/placement-center/src/openraft/store/state_machine_store.rs

@@ -144,7 +144,7 @@ impl StateMachineStore {
     }
 
     fn store(&self) -> &ColumnFamily {
-        self.db.cf_handle("store").unwrap()
+        self.db.cf_handle("_raft_store").unwrap()
     }
 }