This is an automated email from the ASF dual-hosted git repository.
jiajunwang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/helix.git.
from 2676f13 Revert "Merge Waged rebalancer branch code to master. (#724)"
new aed6d7e Define the WAGED rebalancer interfaces.
new 786d238 Adding the configuration items of the WAGED rebalancer. (#348)
new 253851a Implement the WAGED rebalancer cluster model (#362)
new 41aee1b Change the rebalancer assignment record to be ResourceAssignment instead
of IdealState. (#398)
new d4d4941 Convert all the internal assignment state objects to be ResourceAssignment.
(#399)
new 28b65aa Implement Cluster Model Provider. (#392)
new f93aeb5 Add cluster level default instance config. (#413)
new 4372acf Add ChangeDetector interface and ResourceChangeDetector implementation (#388)
new bc6d6f0 Redefine the hard/soft constraints (#422)
new 73e8336 Refine the WAGED rebalancer related interfaces for integration (#431)
new 3995879 Revert "Refine the WAGED rebalancer related interfaces for integration (#431)"
(#437)
new b273df4 Resubmit the change: Refine the WAGED rebalancer related interfaces for
integration (#431)
new 8cbfdce Modify the expected change type from CONFIG to CLUSTER_CONFIG in the WAGED
rebalancer. (#438)
new ff82c34 Add special treatment for ClusterConfig
new 27630a9 Record the replica objects in the AssignableNode in addition to the partition
name (#440)
new eb437c9 Add BucketDataAccessor for large writes
new cf8520a Implement the basic constraint based algorithm (#381)
new 0895c0d Validate the instance capacity/partition weight configuration while constructing
the assignable instances (#451)
new 34a2cf8 Implement the WAGED rebalancer with the limited functionality. (#443)
new dd80b9e HardConstraints Implementation and unit tests (#433)
new a4010e2 Implement AssignmentMetadataStore (#453)
new 63b45ff Fix TestWagedRebalancer and add constructor in AssignmentMetadataStore
new cf7b7a5 Implement one of the soft constraints (#450)
new e49d26b Add soft constraint: ResourcetopStateAntiAffinityConstraint (#465)
new 536062d Implement MaxCapacityUsageInstanceConstraint soft constraint (#463)
new a07296a Add soft constraint: ResourcePartitionAntiAffinityConstraint (#464)
new de800d7 Improve ResourceTopStateAntiAffinityConstraint (#475)
new 7a34f2c Adjust the expected replica count according to fault zone count. (#476)
new d2ffd00 PartitionMovementSoftConstraint Implementation (#474)
new dcc4862 Add the remaining implementation of ConstraintBasedAlgorithmFactory (#478)
new 3e0554b Integrate the WAGED rebalancer with all the related components. (#466)
new 7bb7f57 Separate AssignableNode properties by Immutable and Mutable (#485)
new 71948ec Add delayed rebalance and user-defined preference list features to the WAGED
rebalancer. (#456)
new 95a55d6 Enable maintenance mode for the WAGED rebalancer.
new 43a9bce Adjust the topology processing logic for instance to ensure backward compatibility.
new 081b3f2 Load soft constraint weight from resources/properties file (#492)
new 359d6de Add latency metric components for WAGED rebalancer (#490)
new b287fb5 Fixing rebalance cache issue and stablize the tests. (#510)
new a318890 More strict partition weight validation while creating the cluster model.
(#511)
new 08bc164 Increase parallelism for ZkBucketDataAccessor (#506)
new bc2d0cf The WAGED rebalancer returns the previously calculated assignment on calculation
failure (#514)
new 2d1e8cf Make log clearer after finishing calculateAssignment. (#531)
new 285318a Implement monitoring mbeans for the WAGED rebalancer. (#525)
new afb19a1 Refine the rebalance scope calculating logic in the WAGED rebalancer. (#519)
new b63a895 Make WagedRebalancer static by creating a ThreadLocal (#540)
new f48f4d2 Change change detector to a regular field in the WAGED rebalancer instead
of static threadlocal. (#543)
new 3f237df Refactor soft constraints to simply the algorithm and fix potential issues.
(#520)
new cd3de5a Minor fix for the constraints related tests. (#545)
new dcda863 Adjust the replica rebalance calculating ordering to avoid static order.
(#535)
new e27c6fa Implement increment() method in CountMetric class. (#537)
new f7df84c Modify the ivy file to add the new math3 lib dependency. (#546)
new 6e37673 Fix a missing parameter when the WAGED rebalancer init the change detector.
(#547)
new 76e0fc0 Add the new Rebalancer monitor domain to the active domain list. (#550)
new dc40825 Refine ivy file config. The org were not configured correctly. (#551)
new e5e3689 Use a deep copy of the new best possible assignment for measuring baseline
divergence. (#542)
new 2b3f9fa Add max capacity usage metric for instance monitor. (#548)
new c2b7ac7 Fix formula incorrection in the comment for measuring baseline divergence.
(#559)
new ae22186 Avoid redundant writes in AssignmentMetadataStore (#564)
new 5691d3a Filter resource map with ideal states for instance capacity metrics. (#574)
new 0b1b337 Introduce Dry-run Waged Rebalancer for the verifiers and tests. (#573)
new e93e050 Change ClusterConfig.setDefaultCapacityMap to be private. (#590)
new 8a8478a Add Java API for adding and validating resources for WAGED rebalancer (#570)
new edc8a86 Change calculation for baseline divergence. (#598)
new 435360f Improve the WAGED rebalancer performance. (#586)
new f4b67ae Fix the unstable test TestZeroReplicaAvoidance. (#603)
new 37fd496 Add REST API endpoints for WAGED Rebalancer (#611)
new 6dbc725 Fix a potential issue in the ResourceChangeSnapshot. (#635)
new 4c48d02 Simply and enhance the RebalanceLatencyGauge so it can be used in multi-threads.
(#636)
new 30695f0 Add new WAGED rebalancer config item "GLOBAL_REBALANCE_ASYNC_MODE". (#637)
new a2771cb Decouple the event type and the scheduled rebalance cache refresh option.
(#638)
new 75904ef Improve the algorithm so it prioritizes the assignment to the idle nodes
when the constraint evaluation results are the same (#651)
new 39f3959 Refine the WAGED rebalancer to minimize the partial rebalance workload.
(#639)
new adfaf4e Refine methods name and comments. (#664)
new 6b73653 Asynchronously calculating the Baseline (#632)
new fe4ecb8 Reorgnize the test case so the new WAGED expand cluster tests are not skipped.
(#670)
new a1557df Fix the Helix rest tests by cleaning up the environment before testing.
(#679)
new feb2562 Add instance capacity gauge (#557)
new eb40e15 Add resource partition weight gauge (#686)
new 71c79fd Add WAGED rebalancer reset method to clean up cached status. (#696)
new ec3568d Reset the WAGED rebalancer once the controller newly acquires leadership.
(#690)
The 80 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
helix-core/helix-core-0.9.2-SNAPSHOT.ivy | 3 +-
helix-core/pom.xml | 7 +-
.../java/org/apache/helix/BucketDataAccessor.java | 53 ++
.../src/main/java/org/apache/helix/HelixAdmin.java | 47 ++
.../org/apache/helix/HelixRebalanceException.java | 51 ++
.../main/java/org/apache/helix/InstanceType.java | 6 +-
.../java/org/apache/helix/SystemPropertyKeys.java | 2 +
.../helix/controller/GenericHelixController.java | 129 +++-
.../controller/changedetector/ChangeDetector.java | 57 ++
.../changedetector/ResourceChangeDetector.java | 199 ++++++
.../changedetector/ResourceChangeSnapshot.java | 157 ++++
.../ResourceControllerDataProvider.java | 34 +-
.../rebalancer/DelayedAutoRebalancer.java | 203 +-----
.../controller/rebalancer/StatefulRebalancer.java | 37 +
.../rebalancer/util/DelayedRebalanceUtil.java | 267 +++++++
.../rebalancer/util/ResourceUsageCalculator.java | 192 +++++
.../rebalancer/util/WagedValidationUtil.java | 91 +++
.../rebalancer/waged/AssignmentMetadataStore.java | 213 ++++++
.../rebalancer/waged/RebalanceAlgorithm.java | 43 ++
.../rebalancer/waged/WagedRebalancer.java | 787 +++++++++++++++++++++
.../constraints/ConstraintBasedAlgorithm.java | 228 ++++++
.../ConstraintBasedAlgorithmFactory.java | 82 +++
.../constraints/FaultZoneAwareConstraint.java | 43 ++
.../waged/constraints/HardConstraint.java | 47 ++
.../InstancePartitionsCountConstraint.java | 41 ++
.../MaxCapacityUsageInstanceConstraint.java | 42 ++
.../waged/constraints/NodeCapacityConstraint.java | 50 ++
.../NodeMaxPartitionLimitConstraint.java | 43 ++
.../constraints/PartitionMovementConstraint.java | 96 +++
.../constraints/ReplicaActivateConstraint.java} | 44 +-
.../ResourcePartitionAntiAffinityConstraint.java | 43 ++
.../ResourceTopStateAntiAffinityConstraint.java | 44 ++
.../SamePartitionOnInstanceConstraint.java} | 29 +-
.../waged/constraints/SoftConstraint.java | 90 +++
.../waged/constraints/UsageSoftConstraint.java | 85 +++
.../constraints/ValidGroupTagConstraint.java} | 31 +-
.../rebalancer/waged/model/AssignableNode.java | 374 ++++++++++
.../rebalancer/waged/model/AssignableReplica.java | 161 +++++
.../rebalancer/waged/model/ClusterContext.java | 172 +++++
.../rebalancer/waged/model/ClusterModel.java | 132 ++++
.../waged/model/ClusterModelProvider.java | 532 ++++++++++++++
.../rebalancer/waged/model/OptimalAssignment.java | 93 +++
.../helix/controller/stages/AttributeName.java | 3 +-
.../stages/BestPossibleStateCalcStage.java | 180 ++++-
.../stages/CurrentStateComputationStage.java | 75 ++
.../controller/stages/CurrentStateOutput.java | 23 +
.../org/apache/helix/manager/zk/ZKHelixAdmin.java | 282 +++++++-
.../manager/zk/ZNRecordJacksonSerializer.java | 67 ++
.../helix/manager/zk/ZkBucketDataAccessor.java | 380 ++++++++++
.../java/org/apache/helix/model/ClusterConfig.java | 228 +++++-
.../org/apache/helix/model/InstanceConfig.java | 52 +-
.../org/apache/helix/model/ResourceConfig.java | 129 +++-
.../apache/helix/model/StateModelDefinition.java | 4 +-
.../monitoring/mbeans/ClusterStatusMonitor.java | 92 ++-
.../helix/monitoring/mbeans/InstanceMonitor.java | 192 ++++-
.../monitoring/mbeans/MonitorDomainNames.java | 3 +-
.../helix/monitoring/mbeans/ResourceMonitor.java | 99 ++-
.../mbeans/dynamicMBeans/DynamicMBeanProvider.java | 78 +-
.../mbeans/dynamicMBeans/SimpleDynamicMetric.java | 2 +-
.../helix/monitoring/metrics/MetricCollector.java | 99 +++
.../metrics/WagedRebalancerMetricCollector.java | 125 ++++
.../implementation/BaselineDivergenceGauge.java | 68 ++
.../implementation/RebalanceCounter.java} | 24 +-
.../implementation/RebalanceFailureCount.java} | 24 +-
.../implementation/RebalanceLatencyGauge.java | 89 +++
.../monitoring/metrics/model/CountMetric.java | 69 ++
.../monitoring/metrics/model/LatencyMetric.java | 67 ++
.../model/Metric.java} | 31 +-
.../model/RatioMetric.java} | 46 +-
.../BestPossibleExternalViewVerifier.java | 73 +-
.../StrictMatchExternalViewVerifier.java | 55 +-
.../ClusterVerifiers/ZkHelixClusterVerifier.java | 17 -
.../main/java/org/apache/helix/util/HelixUtil.java | 25 +-
.../java/org/apache/helix/util/RebalanceUtil.java | 7 +-
.../resources/soft-constraint-weight.properties | 26 +
.../java/org/apache/helix/common/ZkTestBase.java | 16 +-
.../changedetector/TestResourceChangeDetector.java | 441 ++++++++++++
.../util/TestResourceUsageCalculator.java | 103 +++
.../waged/MockAssignmentMetadataStore.java | 60 ++
.../waged/TestAssignmentMetadataStore.java | 186 +++++
.../rebalancer/waged/TestWagedRebalancer.java | 524 ++++++++++++++
.../waged/TestWagedRebalancerMetrics.java | 190 +++++
.../waged/constraints/MockRebalanceAlgorithm.java | 84 +++
.../constraints/TestConstraintBasedAlgorithm.java | 72 ++
.../constraints/TestFaultZoneAwareConstraint.java | 79 +++
.../TestInstancePartitionsCountConstraint.java | 63 ++
.../TestMaxCapacityUsageInstanceConstraint.java | 57 ++
.../constraints/TestNodeCapacityConstraint.java | 54 ++
.../TestNodeMaxPartitionLimitConstraint.java | 56 ++
.../TestPartitionActivateConstraint.java | 64 ++
.../TestPartitionMovementConstraint.java | 127 ++++
...estResourcePartitionAntiAffinityConstraint.java | 67 ++
...TestResourceTopStateAntiAffinityConstraint.java | 82 +++
.../TestSamePartitionOnInstanceConstraint.java | 59 ++
.../TestSoftConstraintNormalizeFunction.java | 47 ++
.../constraints/TestValidGroupTagConstraint.java | 66 ++
.../waged/model/AbstractTestClusterModel.java | 204 ++++++
.../waged/model/ClusterModelTestHelper.java | 40 ++
.../rebalancer/waged/model/TestAssignableNode.java | 280 ++++++++
.../waged/model/TestAssignableReplica.java | 167 +++++
.../rebalancer/waged/model/TestClusterContext.java | 93 +++
.../rebalancer/waged/model/TestClusterModel.java | 101 +++
.../waged/model/TestClusterModelProvider.java | 376 ++++++++++
.../waged/model/TestOptimalAssignment.java | 91 +++
.../TestCrushAutoRebalanceNonRack.java | 8 +-
.../rebalancer/CrushRebalancers/TestNodeSwap.java | 4 +-
.../TestDelayedAutoRebalance.java | 49 +-
...stDelayedAutoRebalanceWithDisabledInstance.java | 32 +-
.../TestDelayedAutoRebalanceWithRackaware.java | 2 +-
.../PartitionMigration/TestExpandCluster.java | 4 +-
.../TestPartitionMigrationBase.java | 26 +-
.../TestWagedRebalancerMigration.java | 111 +++
.../rebalancer/TestMixedModeAutoRebalance.java | 181 +++--
.../rebalancer/TestZeroReplicaAvoidance.java | 62 +-
.../WagedRebalancer/TestDelayedWagedRebalance.java | 89 +++
...tDelayedWagedRebalanceWithDisabledInstance.java | 96 +++
.../TestDelayedWagedRebalanceWithRackaware.java | 96 +++
.../TestMixedModeWagedRebalance.java | 58 ++
.../TestWagedExpandCluster.java} | 47 +-
.../WagedRebalancer/TestWagedNodeSwap.java | 294 ++++++++
.../WagedRebalancer/TestWagedRebalance.java | 590 +++++++++++++++
.../TestWagedRebalanceFaultZone.java | 372 ++++++++++
.../TestWagedRebalanceTopologyAware.java | 114 +++
.../helix/manager/zk/TestZkBucketDataAccessor.java | 189 +++++
.../apache/helix/manager/zk/TestZkHelixAdmin.java | 108 +++
.../java/org/apache/helix/mock/MockHelixAdmin.java | 22 +
.../org/apache/helix/model/TestClusterConfig.java | 259 +++++++
.../org/apache/helix/model/TestInstanceConfig.java | 71 +-
.../org/apache/helix/model/TestResourceConfig.java | 186 +++++
.../mbeans/TestClusterStatusMonitor.java | 192 ++++-
.../monitoring/mbeans/TestInstanceMonitor.java | 75 ++
.../monitoring/mbeans/TestResourceMonitor.java | 371 ++++++----
.../mbeans/TestRoutingTableProviderMonitor.java | 10 +-
.../monitoring/mbeans/TestZkClientMonitor.java | 9 +-
.../apache/helix/tools/TestClusterVerifier.java | 76 +-
...eUsageCalculator.MeasureBaselineDivergence.json | 37 +
...chExternalViewVerifier.ComputeIdealMapping.json | 14 +-
.../rest/server/resources/AbstractResource.java | 10 +-
.../server/resources/helix/ClusterAccessor.java | 10 +-
.../server/resources/helix/InstancesAccessor.java | 88 ++-
.../resources/helix/PerInstanceAccessor.java | 49 +-
.../server/resources/helix/ResourceAccessor.java | 152 +++-
.../helix/rest/server/AbstractTestClass.java | 5 +-
.../helix/rest/server/TestClusterAccessor.java | 13 +
.../helix/rest/server/TestInstancesAccessor.java | 77 ++
.../helix/rest/server/TestPerInstanceAccessor.java | 66 ++
.../helix/rest/server/TestResourceAccessor.java | 117 ++-
.../rest/server/util/JerseyUriRequestBuilder.java | 3 +-
148 files changed, 15108 insertions(+), 999 deletions(-)
create mode 100644 helix-core/src/main/java/org/apache/helix/BucketDataAccessor.java
create mode 100644 helix-core/src/main/java/org/apache/helix/HelixRebalanceException.java
create mode 100644 helix-core/src/main/java/org/apache/helix/controller/changedetector/ChangeDetector.java
create mode 100644 helix-core/src/main/java/org/apache/helix/controller/changedetector/ResourceChangeDetector.java
create mode 100644 helix-core/src/main/java/org/apache/helix/controller/changedetector/ResourceChangeSnapshot.java
create mode 100644 helix-core/src/main/java/org/apache/helix/controller/rebalancer/StatefulRebalancer.java
create mode 100644 helix-core/src/main/java/org/apache/helix/controller/rebalancer/util/DelayedRebalanceUtil.java
create mode 100644 helix-core/src/main/java/org/apache/helix/controller/rebalancer/util/WagedValidationUtil.java
create mode 100644 helix-core/src/main/java/org/apache/helix/controller/rebalancer/waged/AssignmentMetadataStore.java
create mode 100644 helix-core/src/main/java/org/apache/helix/controller/rebalancer/waged/RebalanceAlgorithm.java
create mode 100644 helix-core/src/main/java/org/apache/helix/controller/rebalancer/waged/WagedRebalancer.java
create mode 100644 helix-core/src/main/java/org/apache/helix/controller/rebalancer/waged/constraints/ConstraintBasedAlgorithm.java
create mode 100644 helix-core/src/main/java/org/apache/helix/controller/rebalancer/waged/constraints/ConstraintBasedAlgorithmFactory.java
create mode 100644 helix-core/src/main/java/org/apache/helix/controller/rebalancer/waged/constraints/FaultZoneAwareConstraint.java
create mode 100644 helix-core/src/main/java/org/apache/helix/controller/rebalancer/waged/constraints/HardConstraint.java
create mode 100644 helix-core/src/main/java/org/apache/helix/controller/rebalancer/waged/constraints/InstancePartitionsCountConstraint.java
create mode 100644 helix-core/src/main/java/org/apache/helix/controller/rebalancer/waged/constraints/MaxCapacityUsageInstanceConstraint.java
create mode 100644 helix-core/src/main/java/org/apache/helix/controller/rebalancer/waged/constraints/NodeCapacityConstraint.java
create mode 100644 helix-core/src/main/java/org/apache/helix/controller/rebalancer/waged/constraints/NodeMaxPartitionLimitConstraint.java
create mode 100644 helix-core/src/main/java/org/apache/helix/controller/rebalancer/waged/constraints/PartitionMovementConstraint.java
copy helix-core/src/main/java/org/apache/helix/{monitoring/mbeans/InstanceMonitorMBean.java
=> controller/rebalancer/waged/constraints/ReplicaActivateConstraint.java} (50%)
create mode 100644 helix-core/src/main/java/org/apache/helix/controller/rebalancer/waged/constraints/ResourcePartitionAntiAffinityConstraint.java
create mode 100644 helix-core/src/main/java/org/apache/helix/controller/rebalancer/waged/constraints/ResourceTopStateAntiAffinityConstraint.java
copy helix-core/src/main/java/org/apache/helix/{monitoring/mbeans/MonitorDomainNames.java
=> controller/rebalancer/waged/constraints/SamePartitionOnInstanceConstraint.java} (52%)
create mode 100644 helix-core/src/main/java/org/apache/helix/controller/rebalancer/waged/constraints/SoftConstraint.java
create mode 100644 helix-core/src/main/java/org/apache/helix/controller/rebalancer/waged/constraints/UsageSoftConstraint.java
copy helix-core/src/main/java/org/apache/helix/{monitoring/mbeans/MonitorDomainNames.java
=> controller/rebalancer/waged/constraints/ValidGroupTagConstraint.java} (52%)
create mode 100644 helix-core/src/main/java/org/apache/helix/controller/rebalancer/waged/model/AssignableNode.java
create mode 100644 helix-core/src/main/java/org/apache/helix/controller/rebalancer/waged/model/AssignableReplica.java
create mode 100644 helix-core/src/main/java/org/apache/helix/controller/rebalancer/waged/model/ClusterContext.java
create mode 100644 helix-core/src/main/java/org/apache/helix/controller/rebalancer/waged/model/ClusterModel.java
create mode 100644 helix-core/src/main/java/org/apache/helix/controller/rebalancer/waged/model/ClusterModelProvider.java
create mode 100644 helix-core/src/main/java/org/apache/helix/controller/rebalancer/waged/model/OptimalAssignment.java
create mode 100644 helix-core/src/main/java/org/apache/helix/manager/zk/ZNRecordJacksonSerializer.java
create mode 100644 helix-core/src/main/java/org/apache/helix/manager/zk/ZkBucketDataAccessor.java
create mode 100644 helix-core/src/main/java/org/apache/helix/monitoring/metrics/MetricCollector.java
create mode 100644 helix-core/src/main/java/org/apache/helix/monitoring/metrics/WagedRebalancerMetricCollector.java
create mode 100644 helix-core/src/main/java/org/apache/helix/monitoring/metrics/implementation/BaselineDivergenceGauge.java
copy helix-core/src/main/java/org/apache/helix/monitoring/{mbeans/MonitorDomainNames.java
=> metrics/implementation/RebalanceCounter.java} (60%)
copy helix-core/src/main/java/org/apache/helix/monitoring/{mbeans/MonitorDomainNames.java
=> metrics/implementation/RebalanceFailureCount.java} (68%)
create mode 100644 helix-core/src/main/java/org/apache/helix/monitoring/metrics/implementation/RebalanceLatencyGauge.java
create mode 100644 helix-core/src/main/java/org/apache/helix/monitoring/metrics/model/CountMetric.java
create mode 100644 helix-core/src/main/java/org/apache/helix/monitoring/metrics/model/LatencyMetric.java
rename helix-core/src/main/java/org/apache/helix/monitoring/{mbeans/InstanceMonitorMBean.java
=> metrics/model/Metric.java} (53%)
copy helix-core/src/main/java/org/apache/helix/monitoring/{mbeans/dynamicMBeans/SimpleDynamicMetric.java
=> metrics/model/RatioMetric.java} (52%)
create mode 100644 helix-core/src/main/resources/soft-constraint-weight.properties
create mode 100644 helix-core/src/test/java/org/apache/helix/controller/changedetector/TestResourceChangeDetector.java
create mode 100644 helix-core/src/test/java/org/apache/helix/controller/rebalancer/util/TestResourceUsageCalculator.java
create mode 100644 helix-core/src/test/java/org/apache/helix/controller/rebalancer/waged/MockAssignmentMetadataStore.java
create mode 100644 helix-core/src/test/java/org/apache/helix/controller/rebalancer/waged/TestAssignmentMetadataStore.java
create mode 100644 helix-core/src/test/java/org/apache/helix/controller/rebalancer/waged/TestWagedRebalancer.java
create mode 100644 helix-core/src/test/java/org/apache/helix/controller/rebalancer/waged/TestWagedRebalancerMetrics.java
create mode 100644 helix-core/src/test/java/org/apache/helix/controller/rebalancer/waged/constraints/MockRebalanceAlgorithm.java
create mode 100644 helix-core/src/test/java/org/apache/helix/controller/rebalancer/waged/constraints/TestConstraintBasedAlgorithm.java
create mode 100644 helix-core/src/test/java/org/apache/helix/controller/rebalancer/waged/constraints/TestFaultZoneAwareConstraint.java
create mode 100644 helix-core/src/test/java/org/apache/helix/controller/rebalancer/waged/constraints/TestInstancePartitionsCountConstraint.java
create mode 100644 helix-core/src/test/java/org/apache/helix/controller/rebalancer/waged/constraints/TestMaxCapacityUsageInstanceConstraint.java
create mode 100644 helix-core/src/test/java/org/apache/helix/controller/rebalancer/waged/constraints/TestNodeCapacityConstraint.java
create mode 100644 helix-core/src/test/java/org/apache/helix/controller/rebalancer/waged/constraints/TestNodeMaxPartitionLimitConstraint.java
create mode 100644 helix-core/src/test/java/org/apache/helix/controller/rebalancer/waged/constraints/TestPartitionActivateConstraint.java
create mode 100644 helix-core/src/test/java/org/apache/helix/controller/rebalancer/waged/constraints/TestPartitionMovementConstraint.java
create mode 100644 helix-core/src/test/java/org/apache/helix/controller/rebalancer/waged/constraints/TestResourcePartitionAntiAffinityConstraint.java
create mode 100644 helix-core/src/test/java/org/apache/helix/controller/rebalancer/waged/constraints/TestResourceTopStateAntiAffinityConstraint.java
create mode 100644 helix-core/src/test/java/org/apache/helix/controller/rebalancer/waged/constraints/TestSamePartitionOnInstanceConstraint.java
create mode 100644 helix-core/src/test/java/org/apache/helix/controller/rebalancer/waged/constraints/TestSoftConstraintNormalizeFunction.java
create mode 100644 helix-core/src/test/java/org/apache/helix/controller/rebalancer/waged/constraints/TestValidGroupTagConstraint.java
create mode 100644 helix-core/src/test/java/org/apache/helix/controller/rebalancer/waged/model/AbstractTestClusterModel.java
create mode 100644 helix-core/src/test/java/org/apache/helix/controller/rebalancer/waged/model/ClusterModelTestHelper.java
create mode 100644 helix-core/src/test/java/org/apache/helix/controller/rebalancer/waged/model/TestAssignableNode.java
create mode 100644 helix-core/src/test/java/org/apache/helix/controller/rebalancer/waged/model/TestAssignableReplica.java
create mode 100644 helix-core/src/test/java/org/apache/helix/controller/rebalancer/waged/model/TestClusterContext.java
create mode 100644 helix-core/src/test/java/org/apache/helix/controller/rebalancer/waged/model/TestClusterModel.java
create mode 100644 helix-core/src/test/java/org/apache/helix/controller/rebalancer/waged/model/TestClusterModelProvider.java
create mode 100644 helix-core/src/test/java/org/apache/helix/controller/rebalancer/waged/model/TestOptimalAssignment.java
create mode 100644 helix-core/src/test/java/org/apache/helix/integration/rebalancer/PartitionMigration/TestWagedRebalancerMigration.java
create mode 100644 helix-core/src/test/java/org/apache/helix/integration/rebalancer/WagedRebalancer/TestDelayedWagedRebalance.java
create mode 100644 helix-core/src/test/java/org/apache/helix/integration/rebalancer/WagedRebalancer/TestDelayedWagedRebalanceWithDisabledInstance.java
create mode 100644 helix-core/src/test/java/org/apache/helix/integration/rebalancer/WagedRebalancer/TestDelayedWagedRebalanceWithRackaware.java
create mode 100644 helix-core/src/test/java/org/apache/helix/integration/rebalancer/WagedRebalancer/TestMixedModeWagedRebalance.java
copy helix-core/src/test/java/org/apache/helix/integration/rebalancer/{PartitionMigration/TestExpandCluster.java
=> WagedRebalancer/TestWagedExpandCluster.java} (74%)
create mode 100644 helix-core/src/test/java/org/apache/helix/integration/rebalancer/WagedRebalancer/TestWagedNodeSwap.java
create mode 100644 helix-core/src/test/java/org/apache/helix/integration/rebalancer/WagedRebalancer/TestWagedRebalance.java
create mode 100644 helix-core/src/test/java/org/apache/helix/integration/rebalancer/WagedRebalancer/TestWagedRebalanceFaultZone.java
create mode 100644 helix-core/src/test/java/org/apache/helix/integration/rebalancer/WagedRebalancer/TestWagedRebalanceTopologyAware.java
create mode 100644 helix-core/src/test/java/org/apache/helix/manager/zk/TestZkBucketDataAccessor.java
create mode 100644 helix-core/src/test/java/org/apache/helix/model/TestClusterConfig.java
create mode 100644 helix-core/src/test/java/org/apache/helix/model/TestResourceConfig.java
create mode 100644 helix-core/src/test/java/org/apache/helix/monitoring/mbeans/TestInstanceMonitor.java
create mode 100644 helix-core/src/test/resources/TestResourceUsageCalculator.MeasureBaselineDivergence.json
|