diff --git a/src/meta/src/barrier/recovery.rs b/src/meta/src/barrier/recovery.rs
index 1843b67c2af60..2e7d4bafe249f 100644
--- a/src/meta/src/barrier/recovery.rs
+++ b/src/meta/src/barrier/recovery.rs
@@ -166,14 +166,17 @@ where
                 self.source_manager.clone(),
             ));
 
-            let mce = self
-                .hummock_manager
-                .get_current_version()
-                .await
-                .max_committed_epoch;
-
-            if mce != INVALID_EPOCH {
-                command_ctx.wait_epoch_commit(mce).await?;
+            #[cfg(not(test))]
+            {
+                let mce = self
+                    .hummock_manager
+                    .get_current_version()
+                    .await
+                    .max_committed_epoch;
+
+                if mce != INVALID_EPOCH {
+                    command_ctx.wait_epoch_commit(mce).await?;
+                }
             }
 
             let (barrier_complete_tx, mut barrier_complete_rx) =