You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by br...@apache.org on 2021/02/04 12:30:19 UTC
[accumulo] branch main updated (dd0dfd8 -> 95a8df1)
This is an automated email from the ASF dual-hosted git repository.
brianloss pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/accumulo.git.
from dd0dfd8 re #1086: modify ZooLock to use the native zookeeper client (#1896)
add 95a8df1 Add TabletBalancer to SPI package (#1891)
No new revisions were added by this update.
Summary of changes:
.../core/client/MutationsRejectedException.java | 4 +-
.../accumulo/core/client/PluginEnvironment.java | 12 +-
.../core/client/mapred/AccumuloOutputFormat.java | 2 +-
.../client/mapreduce/AccumuloOutputFormat.java | 2 +-
.../org/apache/accumulo/core/conf/Property.java | 6 +-
.../org/apache/accumulo/core/data/TabletId.java | 9 +
.../apache/accumulo/core/dataImpl/KeyExtent.java | 15 +
.../accumulo/core/dataImpl/TabletIdImpl.java | 14 +-
.../manager/balancer/AssignmentParamsImpl.java | 114 +++++
.../core/manager/balancer/BalanceParamsImpl.java | 103 ++++
.../core/manager/balancer/TServerStatusImpl.java | 151 ++++++
.../core/manager/balancer/TableStatisticsImpl.java | 112 +++++
.../core/manager/balancer/TabletServerIdImpl.java | 99 ++++
.../manager/balancer/TabletStatisticsImpl.java | 87 ++++
.../core/spi/balancer/BalancerEnvironment.java | 90 ++++
.../accumulo/core/spi}/balancer/GroupBalancer.java | 159 +++----
.../spi}/balancer/HostRegexTableLoadBalancer.java | 259 +++++-----
.../core/spi}/balancer/RegexGroupBalancer.java | 49 +-
.../core/spi/balancer/SimpleLoadBalancer.java | 178 ++++---
.../core/spi}/balancer/TableLoadBalancer.java | 97 ++--
.../accumulo/core/spi/balancer/TabletBalancer.java | 122 +++++
.../data/TServerStatus.java} | 34 +-
.../data/TableStatistics.java} | 26 +-
.../core/spi/balancer/data/TabletMigration.java | 74 +++
.../data/TabletServerId.java} | 10 +-
.../data/TabletStatistics.java} | 18 +-
.../util/ThrottledBalancerProblemReporter.java | 113 +++++
.../core/spi/common/ServiceEnvironment.java | 4 +-
.../accumulo/core/util/ConfigurationImpl.java | 12 +
.../BaseHostRegexTableLoadBalancerTest.java | 273 +++++++++++
.../core/spi}/balancer/GroupBalancerTest.java | 116 +++--
...tRegexTableLoadBalancerReconfigurationTest.java | 145 ++++++
.../balancer/HostRegexTableLoadBalancerTest.java | 528 +++++++++++++++++++++
.../core/spi/balancer/SimpleLoadBalancerTest.java | 296 ++++++++++++
.../core/spi/balancer/TableLoadBalancerTest.java | 169 +++++++
.../hadoopImpl/mapred/AccumuloRecordWriter.java | 2 +-
.../hadoopImpl/mapreduce/AccumuloRecordWriter.java | 2 +-
.../accumulo/server/ServiceEnvironmentImpl.java | 4 +
.../manager/balancer/BalancerEnvironmentImpl.java | 112 +++++
.../master/balancer/DefaultLoadBalancer.java | 4 +
.../server/master/balancer/GroupBalancer.java | 3 +
.../balancer/HostRegexTableLoadBalancer.java | 3 +
.../server/master/balancer/RegexGroupBalancer.java | 4 +
.../server/master/balancer/TableLoadBalancer.java | 5 +
.../server/master/balancer/TabletBalancer.java | 36 +-
.../server/master/state/TabletMigration.java | 4 +
.../BaseHostRegexTableLoadBalancerTest.java | 1 +
.../master/balancer/ChaoticLoadBalancerTest.java | 170 -------
.../master/balancer/DefaultLoadBalancerTest.java | 1 +
.../server/master/balancer/GroupBalancerTest.java | 1 +
...tRegexTableLoadBalancerReconfigurationTest.java | 1 +
.../balancer/HostRegexTableLoadBalancerTest.java | 1 +
.../master/balancer/TableLoadBalancerTest.java | 1 +
.../java/org/apache/accumulo/master/Master.java | 99 +++-
.../master/MasterClientServiceHandler.java | 13 +-
.../apache/accumulo/master/TabletGroupWatcher.java | 2 +-
.../apache/accumulo/test}/ChaoticLoadBalancer.java | 112 +++--
.../BalanceInPresenceOfOfflineTableIT.java | 8 +-
.../test/functional/ChaoticBalancerIT.java | 2 +-
.../test/functional/RegexGroupBalanceIT.java | 2 +-
.../accumulo/test/ChaoticLoadBalancerTest.java | 173 +++++++
61 files changed, 3541 insertions(+), 727 deletions(-)
create mode 100644 core/src/main/java/org/apache/accumulo/core/manager/balancer/AssignmentParamsImpl.java
create mode 100644 core/src/main/java/org/apache/accumulo/core/manager/balancer/BalanceParamsImpl.java
create mode 100644 core/src/main/java/org/apache/accumulo/core/manager/balancer/TServerStatusImpl.java
create mode 100644 core/src/main/java/org/apache/accumulo/core/manager/balancer/TableStatisticsImpl.java
create mode 100644 core/src/main/java/org/apache/accumulo/core/manager/balancer/TabletServerIdImpl.java
create mode 100644 core/src/main/java/org/apache/accumulo/core/manager/balancer/TabletStatisticsImpl.java
create mode 100644 core/src/main/java/org/apache/accumulo/core/spi/balancer/BalancerEnvironment.java
copy {server/base/src/main/java/org/apache/accumulo/server/master => core/src/main/java/org/apache/accumulo/core/spi}/balancer/GroupBalancer.java (79%)
copy {server/base/src/main/java/org/apache/accumulo/server/master => core/src/main/java/org/apache/accumulo/core/spi}/balancer/HostRegexTableLoadBalancer.java (66%)
copy {server/base/src/main/java/org/apache/accumulo/server/master => core/src/main/java/org/apache/accumulo/core/spi}/balancer/RegexGroupBalancer.java (72%)
copy server/base/src/main/java/org/apache/accumulo/server/master/balancer/DefaultLoadBalancer.java => core/src/main/java/org/apache/accumulo/core/spi/balancer/SimpleLoadBalancer.java (58%)
copy {server/base/src/main/java/org/apache/accumulo/server/master => core/src/main/java/org/apache/accumulo/core/spi}/balancer/TableLoadBalancer.java (53%)
create mode 100644 core/src/main/java/org/apache/accumulo/core/spi/balancer/TabletBalancer.java
copy core/src/main/java/org/apache/accumulo/core/spi/{common/IteratorConfiguration.java => balancer/data/TServerStatus.java} (63%)
copy core/src/main/java/org/apache/accumulo/core/spi/{compaction/CompactionServices.java => balancer/data/TableStatistics.java} (69%)
create mode 100644 core/src/main/java/org/apache/accumulo/core/spi/balancer/data/TabletMigration.java
copy core/src/main/java/org/apache/accumulo/core/spi/{cache/CacheType.java => balancer/data/TabletServerId.java} (80%)
copy core/src/main/java/org/apache/accumulo/core/spi/{compaction/CompactionServices.java => balancer/data/TabletStatistics.java} (73%)
create mode 100644 core/src/main/java/org/apache/accumulo/core/spi/balancer/util/ThrottledBalancerProblemReporter.java
create mode 100644 core/src/test/java/org/apache/accumulo/core/spi/balancer/BaseHostRegexTableLoadBalancerTest.java
copy {server/base/src/test/java/org/apache/accumulo/server/master => core/src/test/java/org/apache/accumulo/core/spi}/balancer/GroupBalancerTest.java (72%)
create mode 100644 core/src/test/java/org/apache/accumulo/core/spi/balancer/HostRegexTableLoadBalancerReconfigurationTest.java
create mode 100644 core/src/test/java/org/apache/accumulo/core/spi/balancer/HostRegexTableLoadBalancerTest.java
create mode 100644 core/src/test/java/org/apache/accumulo/core/spi/balancer/SimpleLoadBalancerTest.java
create mode 100644 core/src/test/java/org/apache/accumulo/core/spi/balancer/TableLoadBalancerTest.java
create mode 100644 server/base/src/main/java/org/apache/accumulo/server/manager/balancer/BalancerEnvironmentImpl.java
delete mode 100644 server/base/src/test/java/org/apache/accumulo/server/master/balancer/ChaoticLoadBalancerTest.java
rename {server/base/src/main/java/org/apache/accumulo/server/master/balancer => test/src/main/java/org/apache/accumulo/test}/ChaoticLoadBalancer.java (51%)
create mode 100644 test/src/test/java/org/apache/accumulo/test/ChaoticLoadBalancerTest.java