You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by vj...@apache.org on 2020/09/16 15:28:33 UTC
[hbase] branch master updated (1bb19e0 -> 35d59dc)
This is an automated email from the ASF dual-hosted git repository.
vjasani pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/hbase.git.
from 1bb19e0 HBASE-25037 Lots of thread pool are changed to non daemon after HBASE-24750 which causes trouble when shutting down (#2407)
add 35d59dc HBASE-24528 : BalancerDecision queue implementation in HMaster with Admin API
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/hadoop/hbase/client/Admin.java | 43 +++++-
.../hadoop/hbase/client/AdminOverAsyncAdmin.java | 13 +-
.../org/apache/hadoop/hbase/client/AsyncAdmin.java | 44 +++++-
.../hadoop/hbase/client/AsyncHBaseAdmin.java | 13 +-
.../hadoop/hbase/client/BalancerDecision.java | 152 +++++++++++++++++++++
.../org/apache/hadoop/hbase/client/LogEntry.java | 26 ++--
.../apache/hadoop/hbase/client/LogQueryFilter.java | 9 +-
.../hadoop/hbase/client/OnlineLogRecord.java | 35 ++---
.../hadoop/hbase/client/RawAsyncHBaseAdmin.java | 89 ++++++------
.../hbase/client/{Row.java => ServerType.java} | 16 +--
.../hadoop/hbase/shaded/protobuf/ProtobufUtil.java | 76 ++++++++++-
.../hbase/shaded/protobuf/RequestConverter.java | 84 +++++++-----
hbase-common/src/main/resources/hbase-default.xml | 11 +-
.../MetricsStochasticBalancerSourceImpl.java | 4 +-
.../src/main/protobuf/HBase.proto | 12 +-
.../src/main/protobuf/server/master/Master.proto | 26 ++++
.../master/RecentLogs.proto} | 23 ++--
.../src/main/protobuf/server/region/Admin.proto | 18 +++
.../hadoop/hbase/master/MasterRpcServices.java | 55 ++++++++
.../hbase/master/balancer/BaseLoadBalancer.java | 11 ++
.../master/balancer/StochasticLoadBalancer.java | 88 +++++++++---
...onHandler.java => BalancerDecisionDetails.java} | 31 +++--
.../hadoop/hbase/namequeues/NamedQueuePayload.java | 35 ++++-
.../hbase/namequeues/RingBufferEnvelope.java | 2 +-
.../hadoop/hbase/namequeues/RpcLogDetails.java | 4 +-
.../impl/BalancerDecisionQueueService.java | 150 ++++++++++++++++++++
.../hbase/namequeues/impl/SlowLogQueueService.java | 29 ++--
.../namequeues/request/NamedQueueGetRequest.java | 17 ++-
.../namequeues/response/NamedQueueGetResponse.java | 15 +-
.../hadoop/hbase/regionserver/HRegionServer.java | 28 ++--
.../hadoop/hbase/regionserver/RSRpcServices.java | 35 ++++-
.../org/apache/hadoop/hbase/client/TestAdmin2.java | 9 +-
.../client/TestAsyncTableGetMultiThreaded.java | 16 ++-
.../hadoop/hbase/master/MockRegionServer.java | 7 +
.../master/balancer/TestBalancerDecision.java | 105 ++++++++++++++
.../balancer/TestStochasticLoadBalancer.java | 3 +
.../hbase/namequeues/TestNamedQueueRecorder.java | 2 +-
.../hbase/namequeues/TestSlowLogAccessor.java | 2 +-
.../hbase/rsgroup/VerifyingRSGroupAdmin.java | 10 ++
hbase-shell/src/main/ruby/hbase/admin.rb | 88 ++++++------
hbase-shell/src/main/ruby/shell.rb | 1 +
...wlog_responses.rb => get_balancer_decisions.rb} | 30 ++--
.../ruby/shell/commands/get_largelog_responses.rb | 5 +-
.../ruby/shell/commands/get_slowlog_responses.rb | 5 +-
hbase-shell/src/test/ruby/hbase/admin_test.rb | 4 +-
.../hadoop/hbase/thrift2/client/ThriftAdmin.java | 9 ++
src/main/asciidoc/_chapters/hbase-default.adoc | 14 ++
47 files changed, 1204 insertions(+), 300 deletions(-)
create mode 100644 hbase-client/src/main/java/org/apache/hadoop/hbase/client/BalancerDecision.java
copy hbase-metrics-api/src/main/java/org/apache/hadoop/hbase/metrics/MetricSet.java => hbase-client/src/main/java/org/apache/hadoop/hbase/client/LogEntry.java (69%)
copy hbase-client/src/main/java/org/apache/hadoop/hbase/client/{Row.java => ServerType.java} (78%)
copy hbase-protocol-shaded/src/main/protobuf/{MapReduce.proto => server/master/RecentLogs.proto} (69%)
copy hbase-server/src/main/java/org/apache/hadoop/hbase/namequeues/{DisruptorExceptionHandler.java => BalancerDecisionDetails.java} (57%)
create mode 100644 hbase-server/src/main/java/org/apache/hadoop/hbase/namequeues/impl/BalancerDecisionQueueService.java
create mode 100644 hbase-server/src/test/java/org/apache/hadoop/hbase/master/balancer/TestBalancerDecision.java
copy hbase-shell/src/main/ruby/shell/commands/{clear_slowlog_responses.rb => get_balancer_decisions.rb} (51%)