Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-25884 Return empty records for disabled balancer in-memory queue (#3263) 

Signed-off-by: stack <stack@apache.org>
Signed-off-by: Duo Zhang <zhangduo@apache.org>
Signed-off-by: Aman Poonia <apoonia@salesforce.com>
This commit is contained in:
Viraj Jasani 2021-05-14 12:54:07 +05:30 committed by GitHub
parent b65733c093
commit 0955a7a22e
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
hbase-server/src/main/java/org/apache/hadoop/hbase/master/MasterRpcServices.java
View File

@ -3428,8 +3428,9 @@ public class MasterRpcServices extends RSRpcServices implements
namedQueueGetRequest.setBalancerDecisionsRequest(request);
NamedQueueGetResponse namedQueueGetResponse =
namedQueueRecorder.getNamedQueueRecords(namedQueueGetRequest);
List<RecentLogs.BalancerDecision> balancerDecisions =
namedQueueGetResponse.getBalancerDecisions();
List<RecentLogs.BalancerDecision> balancerDecisions = namedQueueGetResponse != null ?
namedQueueGetResponse.getBalancerDecisions() :
Collections.emptyList();
return MasterProtos.BalancerDecisionsResponse.newBuilder()
.addAllBalancerDecision(balancerDecisions).build();
}
@ -3446,8 +3447,9 @@ public class MasterRpcServices extends RSRpcServices implements
namedQueueGetRequest.setBalancerRejectionsRequest(request);
NamedQueueGetResponse namedQueueGetResponse =
namedQueueRecorder.getNamedQueueRecords(namedQueueGetRequest);
List<RecentLogs.BalancerRejection> balancerRejections =
namedQueueGetResponse.getBalancerRejections();
List<RecentLogs.BalancerRejection> balancerRejections = namedQueueGetResponse != null ?
namedQueueGetResponse.getBalancerRejections() :
Collections.emptyList();
return MasterProtos.BalancerRejectionsResponse.newBuilder()
.addAllBalancerRejection(balancerRejections).build();
}