diff --git a/store/copr/mpp.go b/store/copr/mpp.go
index 88ac883bbfb40..d1f125aed866d 100644
--- a/store/copr/mpp.go
+++ b/store/copr/mpp.go
@@ -243,6 +243,11 @@ func (m *mppIterator) handleDispatchReq(ctx context.Context, bo *tikv.Backoffer,
 		m.sendError(errors.New(realResp.Error.Msg))
 		return
 	}
+	for _, retry := range realResp.RetryRegions {
+		id := tikv.NewRegionVerID(retry.Id, retry.RegionEpoch.ConfVer, retry.RegionEpoch.Version)
+		logutil.BgLogger().Info("invalid region because tiflash detected stale region", zap.String("region id", id.String()))
+		m.store.GetRegionCache().InvalidateCachedRegionWithReason(id, tikv.EpochNotMatch)
+	}
 	failpoint.Inject("mppNonRootTaskError", func(val failpoint.Value) {
 		if val.(bool) && !req.IsRoot {
 			time.Sleep(1 * time.Second)
diff --git a/store/tikv/region_cache.go b/store/tikv/region_cache.go
index ca0b47f1e5cd0..657d8f5bc9665 100644
--- a/store/tikv/region_cache.go
+++ b/store/tikv/region_cache.go
@@ -1617,6 +1617,11 @@ type RegionVerID struct {
 	ver     uint64
 }
 
+// NewRegionVerID creates a region ver id, which used for invalidating regions.
+func NewRegionVerID(id, confVer, ver uint64) RegionVerID {
+	return RegionVerID{id, confVer, ver}
+}
+
 // GetID returns the id of the region
 func (r *RegionVerID) GetID() uint64 {
 	return r.id