From a0229f56aaa9639fa49940715116d210c10ec88e Mon Sep 17 00:00:00 2001 From: birdstorm Date: Wed, 23 Dec 2020 11:20:41 +0800 Subject: [PATCH] fix key not in region (#104) Signed-off-by: birdstorm --- .../java/org/tikv/common/region/RegionStoreClient.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/src/main/java/org/tikv/common/region/RegionStoreClient.java b/src/main/java/org/tikv/common/region/RegionStoreClient.java index d0c6fd7862..1ca74dfea8 100644 --- a/src/main/java/org/tikv/common/region/RegionStoreClient.java +++ b/src/main/java/org/tikv/common/region/RegionStoreClient.java @@ -1032,20 +1032,20 @@ public class RegionStoreClient extends AbstractRegionStoreClient { this); } - public RegionStoreClient build(TiRegion region, Store store) throws GrpcException { + public synchronized RegionStoreClient build(TiRegion region, Store store) throws GrpcException { return build(region, store, TiStoreType.TiKV); } - public RegionStoreClient build(ByteString key) throws GrpcException { + public synchronized RegionStoreClient build(ByteString key) throws GrpcException { return build(key, TiStoreType.TiKV); } - public RegionStoreClient build(ByteString key, TiStoreType storeType) throws GrpcException { + public synchronized RegionStoreClient build(ByteString key, TiStoreType storeType) throws GrpcException { Pair pair = regionManager.getRegionStorePairByKey(key, storeType); return build(pair.first, pair.second, storeType); } - public RegionStoreClient build(TiRegion region) throws GrpcException { + public synchronized RegionStoreClient build(TiRegion region) throws GrpcException { Store store = regionManager.getStoreById(region.getLeader().getStoreId()); return build(region, store, TiStoreType.TiKV); }