Skip to content

Commit 048d893

Browse files
committed
HBASE-22282 Should deal with error in the callback of RawAsyncHBaseAdmin.splitRegion methods
1 parent 8b45f5d commit 048d893

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
@@ -1371,6 +1371,10 @@ public CompletableFuture<Void> split(TableName tableName, byte[] splitPoint) {
13711371
public CompletableFuture<Void> splitRegion(byte[] regionName) {
13721372
CompletableFuture<Void> future = new CompletableFuture<>();
13731373
addListener(getRegionLocation(regionName), (location, err) -> {
1374+
if (err != null) {
1375+
future.completeExceptionally(err);
1376+
return;
1377+
}
13741378
RegionInfo regionInfo = location.getRegion();
13751379
if (regionInfo.getReplicaId() != RegionInfo.DEFAULT_REPLICA_ID) {
13761380
future
@@ -1401,6 +1405,10 @@ public CompletableFuture<Void> splitRegion(byte[] regionName, byte[] splitPoint)
14011405
"splitPoint is null. If you don't specify a splitPoint, use splitRegion(byte[]) instead");
14021406
CompletableFuture<Void> future = new CompletableFuture<>();
14031407
addListener(getRegionLocation(regionName), (location, err) -> {
1408+
if (err != null) {
1409+
future.completeExceptionally(err);
1410+
return;
1411+
}
14041412
RegionInfo regionInfo = location.getRegion();
14051413
if (regionInfo.getReplicaId() != RegionInfo.DEFAULT_REPLICA_ID) {
14061414
future

0 commit comments

Comments
 (0)