tikv
/
client-java
mirror of https://github.com/tikv/client-java.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

ignore invalid region while decoding EpochNotMatch 

Signed-off-by: iosmanthus <myosmanthustree@gmail.com>
This commit is contained in:
iosmanthus 2023-09-17 13:17:14 +08:00
parent 60f635ed9c
commit 4707c00cc2
No known key found for this signature in database
GPG Key ID: DEE5BAABFE092169
1 changed files with 10 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
src/main/java/org/tikv/common/operation/RegionErrorHandler.java
View File

@ -220,7 +220,16 @@ public class RegionErrorHandler<RespT> implements ErrorHandler<RespT> {
// If the region epoch is not ahead of TiKV's, replace region meta in region cache. // If the region epoch is not ahead of TiKV's, replace region meta in region cache.
for (Metapb.Region meta : currentRegions) { for (Metapb.Region meta : currentRegions) {
// The region needs to be decoded to plain format. // The region needs to be decoded to plain format.
meta = regionManager.getPDClient().getCodec().decodeRegion(meta); try {
meta = regionManager.getPDClient().getCodec().decodeRegion(meta);
} catch (Exception e) {
logger.warn("ignore invalid region: " + meta.toString());
// if the region is invalid, ignore it since the following situation might appear.
// Assuming a region with range [r000, z), then it splits into:
// [r000, x) [x, z), the right region is invalid for keyspace `r000`.
// We should only care about the valid region.
continue;
}
TiRegion region = regionManager.createRegion(meta, backOffer); TiRegion region = regionManager.createRegion(meta, backOffer);
newRegions.add(region); newRegions.add(region);
if (recv.getRegion().getVerID() == region.getVerID()) { if (recv.getRegion().getVerID() == region.getVerID()) {