This is an automated email from the ASF dual-hosted git repository.
jxue pushed a change to branch replica_level_throttle
in repository https://gitbox.apache.org/repos/asf/helix.git.
discard 6b9bddd [Replica Level Throttle] Apply per replica level throttling
logic to Recovery/Load Rebalance and PendingMessage (#1719)
omit 6fb8088 Change throttling logic to per message (#1714)
omit b9e6f63 [Replica Level Throttle] Add per replica rebalance type
compute logic (#1703)
add c1eeec3 Add TopStateUsage constraint to Waged (#1652)
add 7b54647 New PartitionMovementConstraint and
BaselineInfluenceConstraint for Waged (#1658)
add 0ebf61a Increase largest possible rebalance preference ratio (#1668)
add fe4a9bb Improve the WAGED.ConstraintBasedAlgorithm sorting logic to
prioritize replica with larger impact (#1691)
add bee860a Remove the logic that disables the partitions which fails to
be state-transited from the ERROR state. (#1721)
add 6617d91 Clarify error for ZkSessionMismatchedException in
ZkAsyncCallbacks (#1718)
add edb6045 Add PR Template Section for Backward Compatibility Breaking
Changes (#1699)
new 22f32b9 [Replica Level Throttle] Add per replica rebalance type
compute logic (#1703)
new ad02d8d Change throttling logic to per message (#1714)
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (6b9bddd)
\
N -- N -- N refs/heads/replica_level_throttle (ad02d8d)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
The 2 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:
.github/pull_request_template.md | 6 +
.../AbstractPartitionMovementConstraint.java | 86 ++++++
...raint.java => BaselineInfluenceConstraint.java} | 28 +-
.../constraints/ConstraintBasedAlgorithm.java | 222 ++++++++++-----
.../ConstraintBasedAlgorithmFactory.java | 46 +++-
.../MaxCapacityUsageInstanceConstraint.java | 3 +-
.../constraints/PartitionMovementConstraint.java | 83 +-----
...opStateMaxCapacityUsageInstanceConstraint.java} | 19 +-
.../rebalancer/waged/model/AssignableNode.java | 61 +++--
.../rebalancer/waged/model/ClusterContext.java | 36 ++-
.../stages/CurrentStateComputationStage.java | 2 +-
.../stages/IntermediateStateCalcStage.java | 299 ++++++++++++++-------
.../handling/HelixStateTransitionHandler.java | 23 --
.../java/org/apache/helix/model/ClusterConfig.java | 33 ++-
.../constraints/TestConstraintBasedAlgorithm.java | 15 ++
.../TestMaxCapacityUsageInstanceConstraint.java | 2 +-
.../TestPartitionMovementConstraint.java | 111 +++-----
...opStateMaxCapacityUsageInstanceConstraint.java} | 12 +-
.../waged/model/AbstractTestClusterModel.java | 42 +++
.../waged/model/ClusterModelTestHelper.java | 2 +-
.../rebalancer/waged/model/TestAssignableNode.java | 12 +-
.../rebalancer/waged/model/TestClusterContext.java | 4 +
.../org/apache/helix/integration/TestDrop.java | 5 -
.../WagedRebalancer/TestWagedRebalance.java | 12 +-
.../org/apache/helix/model/TestClusterConfig.java | 23 +-
.../apache/helix/zookeeper/zkclient/ZkClient.java | 10 +
.../zkclient/callback/ZkAsyncCallbacks.java | 10 +
.../zookeeper/impl/client/TestRawZkClient.java | 4 +-
28 files changed, 783 insertions(+), 428 deletions(-)
create mode 100644
helix-core/src/main/java/org/apache/helix/controller/rebalancer/waged/constraints/AbstractPartitionMovementConstraint.java
copy
helix-core/src/main/java/org/apache/helix/controller/rebalancer/waged/constraints/{ResourceTopStateAntiAffinityConstraint.java
=> BaselineInfluenceConstraint.java} (59%)
copy
helix-core/src/main/java/org/apache/helix/controller/rebalancer/waged/constraints/{MaxCapacityUsageInstanceConstraint.java
=> TopStateMaxCapacityUsageInstanceConstraint.java} (69%)
copy
helix-core/src/test/java/org/apache/helix/controller/rebalancer/waged/constraints/{TestMaxCapacityUsageInstanceConstraint.java
=> TestTopStateMaxCapacityUsageInstanceConstraint.java} (82%)
