Skip to content

Commit 38ff46f

Browse files
committed
HBASE-22282 Should deal with error in the callback of RawAsyncHBaseAdmin.splitRegion methods
1 parent b0075a1 commit 38ff46f

File tree

1 file changed

+8
-0
lines changed

1 file changed

+8
-0
lines changed

hbase-client/src/main/java/org/apache/hadoop/hbase/client/RawAsyncHBaseAdmin.java

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1367,6 +1367,10 @@ public CompletableFuture<Void> split(TableName tableName, byte[] splitPoint) {
13671367
public CompletableFuture<Void> splitRegion(byte[] regionName) {
13681368
CompletableFuture<Void> future = new CompletableFuture<>();
13691369
addListener(getRegionLocation(regionName), (location, err) -> {
1370+
if (err != null) {
1371+
future.completeExceptionally(err);
1372+
return;
1373+
}
13701374
RegionInfo regionInfo = location.getRegion();
13711375
if (regionInfo.getReplicaId() != RegionInfo.DEFAULT_REPLICA_ID) {
13721376
future
@@ -1397,6 +1401,10 @@ public CompletableFuture<Void> splitRegion(byte[] regionName, byte[] splitPoint)
13971401
"splitPoint is null. If you don't specify a splitPoint, use splitRegion(byte[]) instead");
13981402
CompletableFuture<Void> future = new CompletableFuture<>();
13991403
addListener(getRegionLocation(regionName), (location, err) -> {
1404+
if (err != null) {
1405+
future.completeExceptionally(err);
1406+
return;
1407+
}
14001408
RegionInfo regionInfo = location.getRegion();
14011409
if (regionInfo.getReplicaId() != RegionInfo.DEFAULT_REPLICA_ID) {
14021410
future

0 commit comments

Comments
 (0)