Skip to content

Commit d6ff9fe

Browse files
committed
Fix region cache update error when handle not leader
Signed-off-by: yongman <yming0221@gmail.com>
1 parent 503047f commit d6ff9fe

File tree

1 file changed

+5
-3
lines changed

1 file changed

+5
-3
lines changed

src/region_cache.rs

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -209,9 +209,11 @@ impl<C: RetryClientTrait> RegionCache<C> {
209209
let mut cache = self.region_cache.write().await;
210210
let region_entry = cache
211211
.ver_id_to_region
212-
.get_mut(&ver_id)
213-
.ok_or(Error::EntryNotFoundInRegionCache)?;
214-
region_entry.leader = Some(leader);
212+
.get_mut(&ver_id);
213+
if let Some(region) = region_entry {
214+
region.leader = Some(leader);
215+
}
216+
215217
Ok(())
216218
}
217219

0 commit comments

Comments
 (0)