From 1f62c3b5455ff0f84cbf6c4a6899db49c2f1849d Mon Sep 17 00:00:00 2001 From: Weny Xu Date: Wed, 14 May 2025 20:19:54 +0800 Subject: [PATCH] fix: table metadata collection (#6102) fix: fix collect metadata --- src/meta-srv/src/region/lease_keeper.rs | 16 ++++++++++++---- 1 file changed, 12 insertions(+), 4 deletions(-) diff --git a/src/meta-srv/src/region/lease_keeper.rs b/src/meta-srv/src/region/lease_keeper.rs index 727265941a..77fec7da3b 100644 --- a/src/meta-srv/src/region/lease_keeper.rs +++ b/src/meta-srv/src/region/lease_keeper.rs @@ -166,12 +166,18 @@ impl RegionLeaseKeeper { if let Ok(Some(region_route)) = table_route.region_route(region_id) { return renew_region_lease_via_region_route(®ion_route, datanode_id, region_id) .map(RegionLeaseInfo::from); + } else { + warn!( + "Denied to renew region lease for datanode: {datanode_id}, region_id: {region_id}, region route is not found in table({})", + region_id.table_id() + ); } + } else { + warn!( + "Denied to renew region lease for datanode: {datanode_id}, region_id: {region_id}, table({}) is not found", + region_id.table_id() + ); } - warn!( - "Denied to renew region lease for datanode: {datanode_id}, region_id: {region_id}, table({}) is not found", - region_id.table_id() - ); None } @@ -187,6 +193,8 @@ impl RegionLeaseKeeper { let table_ids = region_ids .into_iter() .map(|region_id| region_id.table_id()) + .collect::>() + .into_iter() .collect::>(); let table_metadata = self.collect_table_metadata(&table_ids).await?; Ok((table_metadata, operating_regions))