This is an automated email from the ASF dual-hosted git repository.
jxue pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/helix.git.
from bbb0554 Remove task requested state (#1723)
new c04f355 [Replica Level Throttle] Add per replica rebalance type
compute logic (#1703)
new 35dd2e7 Change throttling logic to per message (#1714)
new c819bf7 Apply per replica level throttling logic to Recovery/Load
Rebalance and PendingMessage #1719
new 3a737ef Applying per replica logic for entire stage #1724
new f49986e [Replica Level Throttle] Make Pipeline in a correct order and
fixes tests (#1750)
new fbd901a Add test cases for replica level throttling (#1754)
new 17c52da Refactor/clean up code without logic change (#1760)
The 7 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/controller/GenericHelixController.java | 12 +-
.../helix/controller/common/PartitionStateMap.java | 9 +-
.../stages/IntermediateStateCalcStage.java | 785 +++++++++------------
.../controller/stages/MessageGenerationPhase.java | 14 +-
.../helix/controller/stages/MessageOutput.java | 4 +
.../resource/ResourceMessageGenerationPhase.java | 37 -
.../stages/task/TaskMessageGenerationPhase.java | 38 -
.../helix/monitoring/mbeans/ResourceMonitor.java | 58 +-
.../helix/controller/stages/BaseStageTest.java | 9 +
.../stages/TestCancellationMessageGeneration.java | 14 +-
.../stages/TestIntermediateStateCalcStage.java | 60 +-
.../controller/stages/TestRebalancePipeline.java | 27 +-
.../controller/stages/TestRecoveryLoadBalance.java | 225 ------
.../stages/TestReplicaLevelThrottling.java | 263 +++++++
.../stages/TestStateTransitionPriority.java | 95 ++-
.../TestNoThrottleDisabledPartitions.java | 38 +-
.../controller/TestRedundantDroppedMessage.java | 11 +-
.../messaging/p2pMessage/TestP2PMessages.java | 6 +-
.../TestP2PMessagesAvoidDuplicatedMessage.java | 17 +-
.../p2pMessage/TestP2PStateTransitionMessages.java | 16 +-
.../TestP2PWithStateCancellationMessage.java | 16 +-
.../monitoring/mbeans/TestRebalancerMetrics.java | 18 +-
.../test/resources/TestPartitionLevelPriority.json | 2 +-
.../TestRecoveryLoadBalance.MasterSlave.json | 367 ----------
.../TestRecoveryLoadBalance.OnlineOffline.json | 206 ------
.../TestReplicaLevelThrottling.MultiTopStates.json | 281 ++++++++
.../TestReplicaLevelThrottling.SingleTopState.json | 280 ++++++++
27 files changed, 1402 insertions(+), 1506 deletions(-)
delete mode 100644
helix-core/src/main/java/org/apache/helix/controller/stages/resource/ResourceMessageGenerationPhase.java
delete mode 100644
helix-core/src/main/java/org/apache/helix/controller/stages/task/TaskMessageGenerationPhase.java
delete mode 100644
helix-core/src/test/java/org/apache/helix/controller/stages/TestRecoveryLoadBalance.java
create mode 100644
helix-core/src/test/java/org/apache/helix/controller/stages/TestReplicaLevelThrottling.java
delete mode 100644
helix-core/src/test/resources/TestRecoveryLoadBalance.MasterSlave.json
delete mode 100644
helix-core/src/test/resources/TestRecoveryLoadBalance.OnlineOffline.json
create mode 100644
helix-core/src/test/resources/TestReplicaLevelThrottling.MultiTopStates.json
create mode 100644
helix-core/src/test/resources/TestReplicaLevelThrottling.SingleTopState.json
