chore: after rebase fix

Signed-off-by: discord9 <[email protected]>

Author: discord9

src/datanode/src/heartbeat/handler.rs

@@ -136,8 +136,8 @@ impl HeartbeatResponseHandler for RegionHeartbeatResponseHandler {
     fn is_acceptable(&self, ctx: &HeartbeatResponseHandlerContext) -> bool {
         matches!(
             ctx.incoming_message.as_ref(),
-            Some((_, Instruction::OpenRegion { .. }))
-                | Some((_, Instruction::CloseRegion { .. }))
+            Some((_, Instruction::OpenRegions { .. }))
+                | Some((_, Instruction::CloseRegions { .. }))
                 | Some((_, Instruction::DowngradeRegion { .. }))
                 | Some((_, Instruction::UpgradeRegion { .. }))
                 | Some((_, Instruction::FlushRegions { .. }))
@@ -158,7 +158,7 @@ impl HeartbeatResponseHandler for RegionHeartbeatResponseHandler {
         let downgrade_tasks = self.downgrade_tasks.clone();
         let flush_tasks = self.flush_tasks.clone();
         let gc_tasks = self.gc_tasks.clone();
-        let handler = Self::build_handler(instruction)?;
+        let handler = self.build_handler(instruction)?;
         let _handle = common_runtime::spawn_global(async move {
             let reply = handler(HandlerContext {
                 region_server,

src/meta-srv/src/gc_scheduler.rs

@@ -566,7 +566,7 @@ impl GcScheduler {
                 .process_region_gc_with_retry(candidate, &file_refs_manifest, &region_to_peer)
                 .await
             {
-                Ok((report, used_full_listing)) => {
+                Ok((_report, used_full_listing)) => {
                     successful_regions += 1;
                     // Update GC tracker
                     let mut gc_tracker = self.region_gc_tracker.lock().await;