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 e26b2dc Move task framework related update to async operation
new 7cc2a83 drop instance should retry upon NotEmptyException
new fbb679c split data cache
new b2b5d9b Adding new ENUMS and making enum types public to facilitate
mbean metric discovery of library clients.
new 4dedd7e Create specific package for data providers
new de38a8a fixed typo in ZkClientPathMonitor
new c98dfa0 improve unstable test TestResourceThreadpoolSize
The 6 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/common/caches/AbstractDataCache.java | 59 +-
.../helix/common/caches/CurrentStateCache.java | 36 +-
.../helix/common/caches/ExternalViewCache.java | 1 +
.../helix/common/caches/IdealStateCache.java | 3 +-
.../apache/helix/common/caches/PropertyCache.java | 13 +-
.../apache/helix/common/caches/TaskDataCache.java | 29 +-
.../controllers/ControlContextProvider.java} | 33 +-
.../helix/controller/GenericHelixController.java | 146 ++-
.../java/org/apache/helix/controller/LogUtil.java | 8 +-
.../dataproviders/BaseControllerDataProvider.java | 709 ++++++++++++
.../ResourceControllerDataProvider.java | 273 +++++
.../WorkflowControllerDataProvider.java | 270 +++++
.../controller/rebalancer/AbstractRebalancer.java | 34 +-
.../controller/rebalancer/AutoRebalancer.java | 12 +-
.../controller/rebalancer/CustomRebalancer.java | 21 +-
.../rebalancer/DelayedAutoRebalancer.java | 16 +-
.../rebalancer/MaintenanceRebalancer.java | 6 +-
.../helix/controller/rebalancer/Rebalancer.java | 9 +-
.../controller/rebalancer/SemiAutoRebalancer.java | 14 +-
.../rebalancer/internal/MappingCalculator.java | 8 +-
.../AbstractEvenDistributionRebalanceStrategy.java | 12 +-
.../rebalancer/strategy/AutoRebalanceStrategy.java | 6 +-
.../strategy/ConstraintRebalanceStrategy.java | 19 +-
.../strategy/CrushEdRebalanceStrategy.java | 7 +-
.../strategy/CrushRebalanceStrategy.java | 8 +-
.../strategy/MultiRoundCrushRebalanceStrategy.java | 11 +-
.../rebalancer/strategy/RebalanceStrategy.java | 13 +-
.../helix/controller/stages/AttributeName.java | 4 +-
.../stages/BestPossibleStateCalcStage.java | 76 +-
.../helix/controller/stages/ClusterDataCache.java | 1178 --------------------
.../controller/stages/CompatibilityCheckStage.java | 3 +-
.../stages/CurrentStateComputationStage.java | 3 +-
.../stages/ExternalViewComputeStage.java | 32 +-
.../stages/IntermediateStateCalcStage.java | 16 +-
.../controller/stages/MessageDispatchStage.java | 9 +-
.../controller/stages/MessageGenerationPhase.java | 17 +-
.../controller/stages/MessageSelectionStage.java | 5 +-
.../controller/stages/MessageThrottleStage.java | 5 +-
.../controller/stages/PersistAssignmentStage.java | 5 +-
.../controller/stages/ReadClusterDataStage.java | 45 +-
.../stages/ResourceComputationStage.java | 25 +-
.../controller/stages/ResourceValidationStage.java | 3 +-
.../stages/TargetExteralViewCalcStage.java | 5 +-
.../stages/TaskGarbageCollectionStage.java | 12 +-
.../stages/TopStateHandoffReportStage.java | 40 +-
.../stages/task/TaskPersistDataStage.java | 5 +-
.../stages/task/TaskSchedulingStage.java | 16 +-
.../examples/WeightAwareRebalanceUtilExample.java | 2 -
.../org/apache/helix/manager/zk/ZKHelixAdmin.java | 25 +-
.../monitoring/mbeans/ClusterStatusMonitor.java | 7 +-
.../monitoring/mbeans/ZkClientPathMonitor.java | 41 +-
.../apache/helix/task/AbstractTaskDispatcher.java | 36 +-
.../helix/task/DeprecatedTaskRebalancer.java | 36 +-
.../helix/task/FixedTargetTaskRebalancer.java | 9 +-
.../apache/helix/task/GenericTaskRebalancer.java | 6 +-
.../java/org/apache/helix/task/JobDispatcher.java | 41 +-
.../java/org/apache/helix/task/JobRebalancer.java | 8 +-
.../java/org/apache/helix/task/TaskRebalancer.java | 30 +-
.../org/apache/helix/task/WorkflowDispatcher.java | 16 +-
.../org/apache/helix/task/WorkflowRebalancer.java | 8 +-
.../helix/tools/ClusterExternalViewVerifier.java | 20 +-
.../apache/helix/tools/ClusterStateVerifier.java | 14 +-
.../BestPossibleExternalViewVerifier.java | 24 +-
.../StrictMatchExternalViewVerifier.java | 11 +-
.../main/java/org/apache/helix/util/HelixUtil.java | 4 +-
.../helix/util/WeightAwareRebalanceUtil.java | 7 +-
.../TestWorkflowControllerDataProvider.java} | 9 +-
.../rebalancer/TestAutoRebalanceStrategy.java | 4 +-
...stAutoRebalanceStrategyImbalanceAssignment.java | 4 +-
.../TestConstraintRebalanceStrategy.java | 6 +-
.../TestBestPossibleCalcStageCompatibility.java | 5 +
.../stages/TestBestPossibleStateCalcStage.java | 2 +
.../stages/TestCompatibilityCheckStage.java | 3 +
.../stages/TestCurrentStateComputationStage.java | 4 +
.../controller/stages/TestExternalViewStage.java | 5 +-
.../stages/TestIntermediateStateCalcStage.java | 9 +-
.../stages/TestMessageThrottleStage.java | 13 +-
.../TestQuotaConstraintSkipWorkflowAssignment.java | 6 +-
.../controller/stages/TestRebalancePipeline.java | 11 +-
.../controller/stages/TestRecoveryLoadBalance.java | 5 +-
.../stages/TestResourceComputationStage.java | 7 +
.../stages/TestResourceValidationStage.java | 13 +-
.../stages/TestStateTransitionPrirority.java | 5 +
.../helix/controller/stages/TestTaskStage.java | 6 +-
.../integration/TestPersistAssignmentStage.java | 9 +-
...TestControllerDataProviderSelectiveUpdate.java} | 12 +-
.../controller/TestRedundantDroppedMessage.java | 7 +-
.../TestSkipBestPossibleCalculation.java | 9 +-
.../integration/manager/TestHelixDataAccessor.java | 6 +-
.../messaging/TestP2PMessageSemiAuto.java | 4 +-
.../messaging/TestP2PNoDuplicatedMessage.java | 6 +-
.../TestCrushAutoRebalanceNonRack.java | 2 +-
.../TestDelayedAutoRebalance.java | 26 +-
.../integration/rebalancer/TestAutoRebalance.java | 4 +-
.../TestAutoRebalancePartitionLimit.java | 5 +-
.../TestCustomizedIdealStateRebalancer.java | 8 +-
.../helix/integration/task/TaskTestUtil.java | 13 +-
.../handling/TestResourceThreadpoolSize.java | 22 +-
.../TestP2PMessagesAvoidDuplicatedMessage.java | 11 +-
.../p2pMessage/TestP2PStateTransitionMessages.java | 15 +-
.../monitoring/mbeans/TestRebalancerMetrics.java | 8 +-
.../mbeans/TestTopStateHandoffMetrics.java | 14 +-
.../apache/helix/task/TestCleanExpiredJobs.java | 9 +-
.../apache/helix/task/TestJobStateOnCreation.java | 84 ++
.../apache/helix/task/TestScheduleDelayJobs.java | 8 +-
105 files changed, 2174 insertions(+), 1850 deletions(-)
copy helix-core/src/main/java/org/apache/helix/{store/PropertySerializer.java
=> common/controllers/ControlContextProvider.java} (57%)
create mode 100644
helix-core/src/main/java/org/apache/helix/controller/dataproviders/BaseControllerDataProvider.java
create mode 100644
helix-core/src/main/java/org/apache/helix/controller/dataproviders/ResourceControllerDataProvider.java
create mode 100644
helix-core/src/main/java/org/apache/helix/controller/dataproviders/WorkflowControllerDataProvider.java
delete mode 100644
helix-core/src/main/java/org/apache/helix/controller/stages/ClusterDataCache.java
rename
helix-core/src/test/java/org/apache/helix/controller/{stages/TestClusterDataCache.java
=> dataproviders/TestWorkflowControllerDataProvider.java} (87%)
rename
helix-core/src/test/java/org/apache/helix/integration/controller/{TestClusterDataCacheSelectiveUpdate.java
=> TestControllerDataProviderSelectiveUpdate.java} (94%)
create mode 100644
helix-core/src/test/java/org/apache/helix/task/TestJobStateOnCreation.java
