get version id in each retry

src/meta/src/barrier/recovery.rs

@@ -229,17 +229,6 @@ impl GlobalBarrierManager {
     ///
     /// Returns the new state of the barrier manager after recovery.
     pub async fn recovery(&mut self, paused_reason: Option<PausedReason>, err: Option<MetaError>) {
-        let (prev_epoch, version_id) = self
-            .context
-            .hummock_manager
-            .on_current_version(|version| {
-                (
-                    TracedEpoch::new(Epoch::from(version.max_committed_epoch)),
-                    version.id,
-                )
-            })
-            .await;
-
         // Mark blocked and abort buffered schedules, they might be dirty already.
         self.scheduled_barriers
             .abort_and_mark_blocked("cluster is under recovering");
@@ -338,6 +327,17 @@ impl GlobalBarrierManager {
                         .await
                         .context("purge state table from hummock")?;
 
+                    let (prev_epoch, version_id) = self
+                        .context
+                        .hummock_manager
+                        .on_current_version(|version| {
+                            (
+                                TracedEpoch::new(Epoch::from(version.max_committed_epoch)),
+                                version.id,
+                            )
+                        })
+                        .await;
+
                     let mut control_stream_manager =
                         ControlStreamManager::new(self.context.clone());