invalid cache for range exceeds bound

Signed-off-by: shiyuhang <[email protected]>
tikv · Mar 19, 2024 · 8a6527a · 8a6527a
1 parent 533dbc2
commit 8a6527a
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/src/main/java/org/tikv/common/region/RegionStoreClient.java b/src/main/java/org/tikv/common/region/RegionStoreClient.java
@@ -739,6 +739,13 @@ private List<RangeSplitter.RegionTask> handleCopResponse(
 
     String otherError = response.getOtherError();
     if (!otherError.isEmpty()) {
+      // Invalid cache and split ranges for range exceeds bound error
+      if (otherError.contains("range exceeds bound")) {
+        this.regionManager.invalidateRegion(this.region);
+        logger.warn(
+            String.format("Invalid cache and re-splitting region task due to: %s.", otherError));
+        return RangeSplitter.newSplitter(this.regionManager).splitRangeByRegion(ranges, storeType);
+      }
       logger.warn(String.format("Other error occurred, message: %s", otherError));
       throw new GrpcException(otherError);
     }