You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@helix.apache.org by jx...@apache.org on 2019/12/07 01:26:51 UTC
[helix] branch helix-cloud updated (eb6ee21 -> 9280f22)
This is an automated email from the ASF dual-hosted git repository.
jxue pushed a change to branch helix-cloud
in repository https://gitbox.apache.org/repos/asf/helix.git.
from eb6ee21 Revert "Deep copy for mapFields and listFields in ZNRecord's copy constructor. (#552)"
add 554dcd0 Fix partitions double charged for pending message
add d49448a Minor log optimization for easily investigating mastership handoff latency (#576)
add f4ebd3b Update ZkBaseDataAccessor with custom serializer support (#534)
add 0d6a2e2 Avoid workflowContext creation without workflowConfig (#583)
add 0405399 Remove the closing of ZkClient in afterClass() in TestZkBaseDataAccessor (#604)
add 7f9b9b8 Fix unit test failure for TestTaskPerformanceMetrics. (#585)
add 9d440c5 Suggested fixes by iCR, OpenRefactory, Inc. (#528)
add 52cb222 Fix NullPointerException in TestBatchMessage. (#580)
add 644a568 Fix NullPointerException for testCustomCodeRunner. (#581)
add 9ebdaf7 Add a ZkAddress-based constructor for ConfigAccessor (#592)
add 5d8f696 Add new constructors and close() to Helix API (#601)
add bc46dad Stabilize the TestAlertingRebalancerFailure test (#608)
add 8e0ac76 Fix NullPointerException in TestDisableCustomCodeRunner_test. (#617)
add 88296bc Optimize imports for the whole project. (#577)
add a264841 Fix NullPointerException and test failure for testDisablePartitionAndStopInstance. (#613)
add 2dcff16 Replace jcommander Maps and Lists with google common's. (#579)
add 66de313 Modify ZkUtil methods so that they accept ZkAddress as parameter (#606)
add e3a7a0c Add default implementation to new interface methods (#626)
add 634484d Fix RoutingDataCache always requiring full refresh for current state.
add 1d1eae0 Remove unnecessary boxing for boolean values.
add 9935fe5 Add unit test.
add 25ccf97 Remove println.
add b857af7 Format long lines.
add 4d4cca9 Add close() to ClusterSetup to avoid ZkClient leak (#629)
add 9280f22 Stabilize 5 unstable tests (#624)
No new revisions were added by this update.
Summary of changes:
.../org/apache/helix/webapp/HelixAdminWebApp.java | 4 +-
.../apache/helix/webapp/RestAdminApplication.java | 2 +-
.../helix/webapp/resources/ClusterResource.java | 4 +-
.../helix/webapp/resources/ClustersResource.java | 4 +-
.../helix/webapp/resources/ConfigResource.java | 4 +-
.../helix/webapp/resources/ConstraintResource.java | 4 +-
.../helix/webapp/resources/ControllerResource.java | 4 +-
.../resources/ControllerStatusUpdateResource.java | 4 +-
.../webapp/resources/CurrentStateResource.java | 4 +-
.../webapp/resources/CurrentStatesResource.java | 4 +-
.../helix/webapp/resources/ErrorResource.java | 4 +-
.../helix/webapp/resources/ErrorsResource.java | 4 +-
.../webapp/resources/ExternalViewResource.java | 4 +-
.../helix/webapp/resources/IdealStateResource.java | 4 +-
.../helix/webapp/resources/InstanceResource.java | 4 +-
.../helix/webapp/resources/InstancesResource.java | 7 +-
.../helix/webapp/resources/JobQueueResource.java | 8 +-
.../helix/webapp/resources/JobQueuesResource.java | 14 +-
.../apache/helix/webapp/resources/JobResource.java | 4 +-
.../webapp/resources/ResourceGroupResource.java | 4 +-
.../webapp/resources/ResourceGroupsResource.java | 9 +-
.../webapp/resources/SchedulerTasksResource.java | 4 +-
.../helix/webapp/resources/StateModelResource.java | 4 +-
.../webapp/resources/StateModelsResource.java | 4 +-
.../webapp/resources/StatusUpdateResource.java | 4 +-
.../webapp/resources/StatusUpdatesResource.java | 4 +-
.../helix/webapp/resources/WorkflowsResource.java | 7 +-
.../helix/webapp/resources/ZkChildResource.java | 4 +-
.../helix/webapp/resources/ZkPathResource.java | 4 +-
.../org/apache/helix/webapp/AdminTestBase.java | 4 +-
.../webapp/resources/TestJobQueuesResource.java | 2 -
.../org/apache/helix/agent/AgentStateModel.java | 2 +-
.../java/org/apache/helix/BaseDataAccessor.java | 11 +-
.../main/java/org/apache/helix/ConfigAccessor.java | 101 ++++++----
.../src/main/java/org/apache/helix/HelixAdmin.java | 7 +-
.../main/java/org/apache/helix/HelixManager.java | 20 +-
.../main/java/org/apache/helix/InstanceType.java | 2 +-
.../main/java/org/apache/helix/PropertyKey.java | 23 ++-
.../java/org/apache/helix/PropertyPathBuilder.java | 15 +-
.../helix/api/config/HelixConfigProperty.java | 1 +
.../apache/helix/api/config/RebalanceConfig.java | 1 +
.../api/config/StateTransitionThrottleConfig.java | 1 +
.../api/config/StateTransitionTimeoutConfig.java | 1 +
.../helix/api/listeners/ConfigChangeListener.java | 1 +
.../api/listeners/CurrentStateChangeListener.java | 1 +
.../api/listeners/ExternalViewChangeListener.java | 1 +
.../api/listeners/IdealStateChangeListener.java | 1 +
.../listeners/InstanceConfigChangeListener.java | 1 +
.../api/listeners/LiveInstanceChangeListener.java | 1 +
.../helix/api/listeners/MessageListener.java | 1 +
.../listeners/ResourceConfigChangeListener.java | 1 +
.../api/listeners/ScopedConfigChangeListener.java | 1 +
.../AbstractRebalanceHardConstraint.java | 4 +-
.../AbstractRebalanceSoftConstraint.java | 4 +-
.../helix/common/DedupEventBlockingQueue.java | 5 +-
.../helix/common/caches/AbstractDataCache.java | 3 +-
.../helix/common/caches/AbstractDataSnapshot.java | 4 +-
.../helix/common/caches/BasicClusterDataCache.java | 11 +-
.../helix/common/caches/CurrentStateCache.java | 3 +-
.../helix/common/caches/CurrentStateSnapshot.java | 6 +-
.../helix/common/caches/ExternalViewCache.java | 4 +-
.../helix/common/caches/IdealStateCache.java | 4 +-
.../helix/common/caches/InstanceMessagesCache.java | 8 +-
.../apache/helix/common/caches/PropertyCache.java | 5 +-
.../apache/helix/common/caches/TaskDataCache.java | 1 +
.../helix/controller/ExternalViewGenerator.java | 2 +-
.../helix/controller/GenericHelixController.java | 5 +-
.../helix/controller/common/PartitionStateMap.java | 4 +-
.../helix/controller/common/ResourcesStateMap.java | 4 +-
.../dataproviders/BaseControllerDataProvider.java | 26 +--
.../WorkflowControllerDataProvider.java | 10 +-
.../controller/pipeline/PipelineRegistry.java | 1 +
.../controller/rebalancer/AbstractRebalancer.java | 1 +
.../controller/rebalancer/CustomRebalancer.java | 1 +
.../rebalancer/DelayedAutoRebalancer.java | 1 +
.../rebalancer/MaintenanceRebalancer.java | 1 +
.../PartitionWeightAwareEvennessConstraint.java | 6 +-
.../constraint/TotalCapacityConstraint.java | 6 +-
.../dataprovider/ZkBasedCapacityProvider.java | 12 +-
.../ZkBasedPartitionWeightProvider.java | 12 +-
.../strategy/ConstraintRebalanceStrategy.java | 3 +-
.../rebalancer/strategy/RebalanceStrategy.java | 1 +
.../crushMapping/CRUSHPlacementAlgorithm.java | 4 +-
.../rebalancer/util/RebalanceScheduler.java | 17 +-
.../rebalancer/util/ResourceUsageCalculator.java | 6 +-
.../controller/stages/BestPossibleStateOutput.java | 1 -
.../helix/controller/stages/ClusterDataCache.java | 1 +
.../helix/controller/stages/ClusterEvent.java | 2 +-
.../controller/stages/CompatibilityCheckStage.java | 2 +-
.../stages/CurrentStateComputationStage.java | 9 +-
.../controller/stages/CurrentStateOutput.java | 4 +-
.../stages/IntermediateStateCalcStage.java | 49 ++++-
.../stages/MaintenanceRecoveryStage.java | 1 +
.../controller/stages/MessageDispatchStage.java | 2 +-
.../controller/stages/MessageGenerationPhase.java | 4 +-
.../controller/stages/MessageThrottleStage.java | 8 +-
.../controller/stages/PersistAssignmentStage.java | 2 +-
.../controller/stages/ReadClusterDataStage.java | 7 +-
.../stages/ResourceComputationStage.java | 3 +-
.../controller/stages/ResourceValidationStage.java | 2 +-
.../stages/TargetExteralViewCalcStage.java | 6 +-
.../stages/TaskGarbageCollectionStage.java | 1 +
.../resource/ResourceMessageGenerationPhase.java | 2 +-
.../stages/task/TaskMessageGenerationPhase.java | 2 +-
.../stages/task/TaskSchedulingStage.java | 3 +-
.../controller/strategy/AutoRebalanceStrategy.java | 10 +-
.../apache/helix/examples/BootstrapProcess.java | 4 +-
.../examples/WeightAwareRebalanceUtilExample.java | 8 +-
.../ParticipantHealthReportCollectorImpl.java | 2 +-
.../apache/helix/manager/zk/CallbackHandler.java | 13 +-
.../zk/DefaultControllerMessageHandlerFactory.java | 3 +-
...faultParticipantErrorMessageHandlerFactory.java | 3 +-
.../manager/zk/DistributedLeaderElection.java | 27 +--
.../apache/helix/manager/zk/HelixGroupCommit.java | 3 +-
.../apache/helix/manager/zk/WriteThroughCache.java | 2 +-
.../org/apache/helix/manager/zk/ZKHelixAdmin.java | 13 +-
.../helix/manager/zk/ZKHelixDataAccessor.java | 2 +-
.../apache/helix/manager/zk/ZKHelixManager.java | 3 +-
.../java/org/apache/helix/manager/zk/ZKUtil.java | 216 ++++++++++++++++++++-
.../helix/manager/zk/ZNRecordSerializer.java | 4 +-
.../manager/zk/ZNRecordStreamingSerializer.java | 7 +-
.../apache/helix/manager/zk/ZkAsyncCallbacks.java | 4 +-
.../helix/manager/zk/ZkBaseDataAccessor.java | 39 ++++
.../helix/manager/zk/ZkCacheBaseDataAccessor.java | 21 +-
.../apache/helix/manager/zk/ZkCallbackCache.java | 4 +-
.../zk/serializer/JacksonPayloadSerializer.java | 4 +-
.../helix/manager/zk/zookeeper/ZkClient.java | 2 +-
.../messaging/handling/AsyncCallbackService.java | 3 +-
.../handling/HelixStateTransitionHandler.java | 2 +-
.../messaging/handling/HelixTaskExecutor.java | 1 +
.../java/org/apache/helix/model/ClusterConfig.java | 3 +-
.../org/apache/helix/model/InstanceConfig.java | 3 +-
.../java/org/apache/helix/model/LiveInstance.java | 1 +
.../main/java/org/apache/helix/model/Message.java | 2 +-
.../org/apache/helix/model/ParticipantHistory.java | 6 +-
.../org/apache/helix/model/ResourceConfig.java | 2 +-
.../helix/model/builder/AutoModeISBuilder.java | 4 +-
.../model/builder/AutoRebalanceModeISBuilder.java | 4 +-
.../helix/model/builder/ConstraintItemBuilder.java | 2 +-
.../helix/model/builder/CustomModeISBuilder.java | 4 +-
.../helix/model/builder/FullAutoModeISBuilder.java | 4 +-
.../helix/model/builder/SemiAutoModeISBuilder.java | 4 +-
.../model/util/StateModelDefinitionValidator.java | 5 +-
.../helix/monitoring/ZKPathDataDumpTask.java | 5 +-
.../monitoring/mbeans/ClusterEventMonitor.java | 10 +-
.../monitoring/mbeans/ClusterMBeanObserver.java | 1 -
.../monitoring/mbeans/ClusterStatusMonitor.java | 8 +-
.../monitoring/mbeans/HelixCallbackMonitor.java | 10 +-
.../apache/helix/monitoring/mbeans/JobMonitor.java | 5 +-
.../helix/monitoring/mbeans/MBeanRegistrar.java | 10 +-
.../monitoring/mbeans/MessageLatencyMonitor.java | 10 +-
.../monitoring/mbeans/MessageQueueMonitor.java | 1 -
.../mbeans/ParticipantStatusMonitor.java | 20 +-
.../mbeans/PerInstanceResourceMonitor.java | 7 +-
.../helix/monitoring/mbeans/ResourceMonitor.java | 5 +-
.../mbeans/RoutingTableProviderMonitor.java | 14 +-
.../mbeans/StateTransitionStatMonitor.java | 6 +-
.../helix/monitoring/mbeans/ZkClientMonitor.java | 8 +-
.../monitoring/mbeans/ZkClientPathMonitor.java | 4 +-
.../mbeans/dynamicMBeans/DynamicMBeanProvider.java | 12 +-
.../mbeans/dynamicMBeans/DynamicMetric.java | 6 +-
.../dynamicMBeans/HistogramDynamicMetric.java | 12 +-
.../DistClusterControllerStateModel.java | 3 +-
.../DistClusterControllerStateModelFactory.java | 3 +-
.../participant/GenericLeaderStandbyModel.java | 2 +-
.../helix/participant/HelixCustomCodeRunner.java | 2 +-
.../helix/participant/HelixStateMachineEngine.java | 3 +-
.../apache/helix/spectator/RoutingDataCache.java | 4 +-
.../org/apache/helix/spectator/RoutingTable.java | 1 +
.../helix/spectator/RoutingTableProvider.java | 33 ++--
.../helix/spectator/RoutingTableSnapshot.java | 1 +
.../apache/helix/store/PropertyJsonSerializer.java | 4 +-
.../helix/store/zk/AutoFallbackPropertyStore.java | 2 +-
.../apache/helix/task/AbstractTaskDispatcher.java | 7 +-
.../helix/task/AssignableInstanceManager.java | 1 +
.../helix/task/DeprecatedTaskRebalancer.java | 15 +-
.../task/FixedTargetTaskAssignmentCalculator.java | 5 +-
.../task/GenericTaskAssignmentCalculator.java | 5 +-
.../main/java/org/apache/helix/task/JobConfig.java | 9 +-
.../java/org/apache/helix/task/JobContext.java | 5 +-
.../main/java/org/apache/helix/task/JobDag.java | 8 +-
.../java/org/apache/helix/task/JobDispatcher.java | 3 +-
.../main/java/org/apache/helix/task/JobQueue.java | 4 +-
.../java/org/apache/helix/task/RuntimeJobDag.java | 2 +-
.../helix/task/TaskAssignmentCalculator.java | 8 +-
.../java/org/apache/helix/task/TaskConfig.java | 3 +-
.../java/org/apache/helix/task/TaskDriver.java | 1 +
.../org/apache/helix/task/TaskExecutionInfo.java | 1 +
.../apache/helix/task/TaskStateModelFactory.java | 2 +-
.../main/java/org/apache/helix/task/TaskUtil.java | 6 +-
.../ThreadCountBasedTaskAssignmentCalculator.java | 2 +
.../org/apache/helix/task/WorkflowDispatcher.java | 17 +-
.../org/apache/helix/task/WorkflowRebalancer.java | 3 +-
.../helix/task/assigner/AssignableInstance.java | 1 +
.../apache/helix/task/assigner/TaskAssigner.java | 1 +
.../assigner/ThreadCountBasedTaskAssigner.java | 1 +
.../helix/tools/ClusterExternalViewVerifier.java | 1 +
.../java/org/apache/helix/tools/ClusterSetup.java | 26 ++-
.../apache/helix/tools/ClusterStateVerifier.java | 3 +-
.../org/apache/helix/tools/ClusterVerifier.java | 8 +-
.../BestPossibleExternalViewVerifier.java | 22 +--
.../ClusterVerifiers/HelixClusterVerifier.java | 7 +
.../StrictMatchExternalViewVerifier.java | 6 +-
.../ClusterVerifiers/ZkHelixClusterVerifier.java | 20 +-
.../java/org/apache/helix/tools/RUSHrHash.java | 4 +-
.../helix/tools/StateModelConfigGenerator.java | 2 +-
.../java/org/apache/helix/tools/TestExecutor.java | 1 +
.../tools/commandtools/CurrentStateCleanUp.java | 1 +
.../tools/commandtools/ExampleParticipant.java | 1 +
.../apache/helix/tools/commandtools/JmxDumper.java | 1 -
.../apache/helix/tools/commandtools/TaskAdmin.java | 3 +-
.../apache/helix/tools/commandtools/ToolsUtil.java | 2 +-
.../helix/tools/commandtools/ZKLogFormatter.java | 5 +-
.../main/java/org/apache/helix/util/HelixUtil.java | 4 +-
.../apache/helix/util/InstanceValidationUtil.java | 3 +-
.../org/apache/helix/util/StatusUpdateUtil.java | 1 +
.../helix/util/WeightAwareRebalanceUtil.java | 18 +-
.../scripts/integration-test/script/cm_driver.py | 2 +-
.../scripts/integration-test/script/dds_driver.py | 214 ++++++++++----------
.../scripts/integration-test/script/utility.py | 101 +++++-----
.../test/java/org/apache/helix/MockAccessor.java | 1 +
.../java/org/apache/helix/ScriptTestHelper.java | 1 +
.../java/org/apache/helix/TestConfigAccessor.java | 1 +
.../TestEspressoStorageClusterIdealState.java | 1 +
.../java/org/apache/helix/TestGetProperty.java | 1 +
.../java/org/apache/helix/TestGroupCommit.java | 1 +
.../org/apache/helix/TestHelixConfigAccessor.java | 1 +
.../org/apache/helix/TestHelixTaskHandler.java | 1 +
.../org/apache/helix/TestListenerCallback.java | 1 +
.../helix/TestListenerCallbackBatchMode.java | 1 +
.../apache/helix/TestListenerCallbackPrefetch.java | 1 +
.../helix/TestRelayIdealStateCalculator.java | 1 +
.../java/org/apache/helix/TestRoutingTable.java | 1 +
.../org/apache/helix/TestShuffledIdealState.java | 1 +
.../test/java/org/apache/helix/TestZKCallback.java | 1 +
.../apache/helix/TestZKRoutingInfoProvider.java | 1 +
.../test/java/org/apache/helix/TestZNRecord.java | 1 +
.../test/java/org/apache/helix/TestZkBasis.java | 1 +
.../java/org/apache/helix/TestZnodeModify.java | 1 +
.../test/java/org/apache/helix/ZkTestHelper.java | 1 +
.../java/org/apache/helix/common/ZkTestBase.java | 2 +-
.../common/caches/TestCurrentStateSnapshot.java | 1 +
.../helix/common/caches/TestPropertyCache.java | 9 +-
.../TestWorkflowControllerDataProvider.java | 35 ++--
.../rebalancer/TestAbstractRebalancer.java | 1 +
.../rebalancer/TestAutoRebalanceStrategy.java | 9 +-
...stAutoRebalanceStrategyImbalanceAssignment.java | 1 +
.../TestConstraintRebalanceStrategy.java | 1 +
.../rebalancer/TestZeroReplicaAvoidance.java | 1 +
.../dataprovider/MockCapacityProvider.java | 1 +
.../dataprovider/MockPartitionWeightProvider.java | 1 +
.../helix/controller/stages/BaseStageTest.java | 1 +
.../controller/stages/DummyClusterManager.java | 1 +
.../TestBestPossibleCalcStageCompatibility.java | 1 +
.../stages/TestBestPossibleStateCalcStage.java | 1 +
.../stages/TestClusterEventBlockingQueue.java | 7 +-
.../stages/TestCompatibilityCheckStage.java | 1 +
.../stages/TestCurrentStateComputationStage.java | 1 +
.../controller/stages/TestExternalViewStage.java | 1 +
.../stages/TestIntermediateStateCalcStage.java | 79 ++++----
.../stages/TestMessageThrottleStage.java | 1 +
.../controller/stages/TestMsgSelectionStage.java | 1 +
.../TestQuotaConstraintSkipWorkflowAssignment.java | 1 +
.../controller/stages/TestRebalancePipeline.java | 1 +
.../controller/stages/TestRecoveryLoadBalance.java | 1 +
.../stages/TestResourceComputationStage.java | 1 +
.../stages/TestResourceValidationStage.java | 3 +-
.../stages/TestStateTransitionPriority.java | 3 +-
.../TestStateTransitionThrottleController.java | 11 +-
.../TestCardDealingAdjustmentAlgorithmV2.java | 9 +-
.../TestParticipantHealthReportCollectorImpl.java | 1 +
.../SinglePartitionLeaderStandByTest.java | 1 +
.../apache/helix/integration/TestAddClusterV2.java | 1 +
.../TestAddNodeAfterControllerStart.java | 1 +
.../TestAddStateModelFactoryAfterConnect.java | 1 +
.../integration/TestAlertingRebalancerFailure.java | 7 +-
.../helix/integration/TestBasicSpectator.java | 1 +
.../integration/TestBatchEnableInstances.java | 1 +
.../integration/TestBatchMessageHandling.java | 1 +
.../helix/integration/TestBucketizedResource.java | 1 +
.../integration/TestCMWithFailParticipant.java | 1 +
.../integration/TestCarryOverBadCurState.java | 1 +
.../helix/integration/TestCleanupExternalView.java | 1 +
.../helix/integration/TestClusterStartsup.java | 1 +
.../TestCorrectnessOnConnectivityLoss.java | 4 +-
.../org/apache/helix/integration/TestDisable.java | 1 +
.../integration/TestDisableCustomCodeRunner.java | 17 +-
.../helix/integration/TestDisableExternalView.java | 1 +
.../helix/integration/TestDisablePartition.java | 5 +-
.../helix/integration/TestDisableResource.java | 1 +
.../helix/integration/TestDistributedCMMain.java | 1 +
.../TestDistributedClusterController.java | 1 +
.../org/apache/helix/integration/TestDrop.java | 17 +-
.../TestEnablePartitionDuringDisable.java | 1 +
.../integration/TestEntropyFreeNodeBounce.java | 1 +
.../helix/integration/TestErrorPartition.java | 1 +
.../helix/integration/TestErrorReplicaPersist.java | 1 +
.../helix/integration/TestExpandCluster.java | 1 +
.../apache/helix/integration/TestExternalCmd.java | 1 +
.../helix/integration/TestExternalViewUpdates.java | 1 +
.../helix/integration/TestFailOverPerf1kp.java | 1 +
.../integration/TestHelixCustomCodeRunner.java | 24 +--
.../helix/integration/TestHelixInstanceTag.java | 1 +
.../integration/TestHelixUsingDifferentParams.java | 1 +
.../integration/TestInvalidResourceRebalance.java | 3 +-
.../TestMessagePartitionStateMismatch.java | 1 +
.../TestNoThrottleDisabledPartitions.java | 1 +
.../apache/helix/integration/TestNullReplica.java | 1 +
.../TestPartitionLevelTransitionConstraint.java | 1 +
.../integration/TestPartitionMovementThrottle.java | 5 +-
.../apache/helix/integration/TestPauseSignal.java | 1 +
.../integration/TestPersistAssignmentStage.java | 1 +
.../integration/TestPreferenceListAsQueue.java | 3 +-
.../TestRebalancerPersistAssignments.java | 1 +
.../TestReelectedPipelineCorrectness.java | 1 +
.../helix/integration/TestRenamePartition.java | 1 +
.../helix/integration/TestResetInstance.java | 1 +
.../helix/integration/TestResetPartitionState.java | 1 +
.../helix/integration/TestResetResource.java | 1 +
.../integration/TestResourceGroupEndtoEnd.java | 1 +
.../TestResourceWithSamePartitionKey.java | 1 +
.../apache/helix/integration/TestSchemataSM.java | 1 +
.../integration/TestSessionExpiryInTransition.java | 1 +
.../helix/integration/TestStandAloneCMMain.java | 1 +
.../integration/TestStandAloneCMSessionExpiry.java | 1 +
.../TestStartMultipleControllersWithSameName.java | 1 +
.../TestStateTransitionCancellation.java | 1 +
.../integration/TestStateTransitionThrottle.java | 1 +
.../apache/helix/integration/TestStatusUpdate.java | 1 +
.../integration/TestWeightBasedRebalanceUtil.java | 1 +
.../integration/TestZkCallbackHandlerLeak.java | 1 +
.../helix/integration/TestZkSessionExpiry.java | 3 +-
.../integration/common/ZkStandAloneCMTestBase.java | 1 +
.../controller/TestClusterMaintenanceMode.java | 3 +-
.../controller/TestControllerHistory.java | 1 +
.../controller/TestControllerLeadershipChange.java | 1 +
.../controller/TestControllerLiveLock.java | 1 +
.../TestGenericHelixControllerThreading.java | 1 +
.../controller/TestRedundantDroppedMessage.java | 1 +
.../controller/TestTargetExternalView.java | 1 +
.../manager/ClusterControllerManager.java | 1 +
.../manager/ClusterDistributedController.java | 1 +
.../manager/MockParticipantManager.java | 1 +
.../manager/TestConsecutiveZkSessionExpiry.java | 1 +
.../integration/manager/TestControllerManager.java | 1 +
.../manager/TestDistributedControllerManager.java | 1 +
.../integration/manager/TestHelixDataAccessor.java | 1 +
.../manager/TestParticipantManager.java | 1 +
.../integration/manager/TestStateModelLeak.java | 1 +
.../integration/manager/TestZkHelixAdmin.java | 1 +
.../helix/integration/manager/ZkTestManager.java | 1 +
.../integration/messaging/TestBatchMessage.java | 20 +-
.../messaging/TestBatchMessageWrapper.java | 1 +
.../messaging/TestGroupCommitAddBackData.java | 1 +
.../integration/messaging/TestMessageThrottle.java | 1 +
.../messaging/TestMessageThrottle2.java | 1 +
.../messaging/TestMessagingService.java | 3 +-
.../messaging/TestP2PMessageSemiAuto.java | 1 +
.../messaging/TestP2PNoDuplicatedMessage.java | 1 +
.../messaging/TestP2PSingleTopState.java | 1 +
.../messaging/TestSchedulerMessage.java | 3 +-
.../messaging/TestSchedulerMessage2.java | 1 +
.../messaging/TestSchedulerMsgContraints.java | 1 +
.../messaging/TestSchedulerMsgUsingQueue.java | 1 +
.../paticipant/TestInstanceHistory.java | 1 +
.../paticipant/TestNonOfflineInitState.java | 1 +
.../paticipant/TestParticipantErrorMessage.java | 1 +
.../paticipant/TestParticipantNameCollision.java | 1 +
.../paticipant/TestRestartParticipant.java | 1 +
.../paticipant/TestStateTransitionTimeout.java | 1 +
.../TestStateTransitionTimeoutWithResource.java | 1 +
.../CrushRebalancers/TestCrushAutoRebalance.java | 1 +
.../TestCrushAutoRebalanceNonRack.java | 1 +
...stCrushAutoRebalanceTopoplogyAwareDisabled.java | 1 +
.../TestDelayedAutoRebalance.java | 2 +-
...stDelayedAutoRebalanceWithDisabledInstance.java | 2 +-
.../TestDelayedAutoRebalanceWithRackaware.java | 1 +
.../PartitionMigration/TestExpandCluster.java | 1 +
.../PartitionMigration/TestFullAutoMigration.java | 1 +
.../TestPartitionMigrationBase.java | 1 +
.../rebalancer/TestAutoIsWithEmptyMap.java | 1 +
.../integration/rebalancer/TestAutoRebalance.java | 1 +
.../TestAutoRebalancePartitionLimit.java | 1 +
.../TestAutoRebalanceWithDisabledInstance.java | 1 +
...rInMaintenanceModeWhenReachingMaxPartition.java | 1 +
...nanceModeWhenReachingOfflineInstancesLimit.java | 4 +-
.../rebalancer/TestCustomIdealState.java | 1 +
.../rebalancer/TestCustomRebalancer.java | 3 +-
.../TestCustomizedIdealStateRebalancer.java | 4 +-
.../rebalancer/TestFullAutoNodeTagging.java | 9 +-
.../rebalancer/TestMixedModeAutoRebalance.java | 2 +-
.../rebalancer/TestSemiAutoRebalance.java | 1 +
.../rebalancer/TestZeroReplicaAvoidance.java | 1 +
.../spectator/TestRoutingTableProvider.java | 1 +
.../TestRoutingTableProviderFromCurrentStates.java | 8 +-
.../TestRoutingTableProviderPeriodicRefresh.java | 1 +
.../spectator/TestRoutingTableSnapshot.java | 1 +
.../apache/helix/integration/task/MockTask.java | 1 +
.../helix/integration/task/TaskTestUtil.java | 1 +
.../helix/integration/task/TestBatchAddJobs.java | 1 +
.../task/TestDisableJobExternalView.java | 3 +-
.../task/TestDropOnParticipantReset.java | 1 +
.../helix/integration/task/TestExecutionDelay.java | 11 --
.../integration/task/TestForceDeleteWorkflow.java | 5 +-
.../helix/integration/task/TestGenericJobs.java | 1 +
.../task/TestIndependentTaskRebalancer.java | 7 +-
.../integration/task/TestJobAndWorkflowType.java | 1 +
.../helix/integration/task/TestJobFailure.java | 5 +-
.../integration/task/TestJobFailureDependence.java | 3 +-
.../task/TestJobFailureTaskNotStarted.java | 7 +-
.../integration/task/TestJobQueueCleanUp.java | 3 +-
.../helix/integration/task/TestJobTimeout.java | 3 +-
.../task/TestJobTimeoutTaskNotStarted.java | 3 +-
.../helix/integration/task/TestNoDoubleAssign.java | 3 +-
.../integration/task/TestQuotaBasedScheduling.java | 3 +-
.../integration/task/TestRebalanceRunningTask.java | 5 +-
.../integration/task/TestRecurringJobQueue.java | 5 +-
.../integration/task/TestRetrieveWorkflows.java | 1 +
.../task/TestRunJobsWithMissingTarget.java | 3 +-
.../helix/integration/task/TestRuntimeJobDag.java | 1 +
.../helix/integration/task/TestStopWorkflow.java | 53 +++--
.../task/TestStopWorkflowWithExecutionDelay.java | 6 +-
.../helix/integration/task/TestTaskAssignment.java | 1 +
.../task/TestTaskAssignmentCalculator.java | 5 +-
.../integration/task/TestTaskConditionalRetry.java | 1 +
.../integration/task/TestTaskErrorReporting.java | 1 +
.../helix/integration/task/TestTaskRebalancer.java | 5 +-
.../task/TestTaskRebalancerFailover.java | 3 +-
.../task/TestTaskRebalancerParallel.java | 1 +
.../task/TestTaskRebalancerStopResume.java | 9 +-
.../helix/integration/task/TestTaskStopQueue.java | 8 +-
.../helix/integration/task/TestTaskThreadLeak.java | 1 +
.../helix/integration/task/TestTaskThrottling.java | 3 +-
.../helix/integration/task/TestUpdateWorkflow.java | 3 +-
.../integration/task/TestUserContentStore.java | 5 +-
.../task/TestWorkflowContextWithoutConfig.java | 132 +++++++++++++
.../integration/task/TestWorkflowTermination.java | 5 +-
.../integration/task/TestWorkflowTimeout.java | 3 +-
.../helix/integration/task/WorkflowGenerator.java | 1 +
.../org/apache/helix/manager/MockListener.java | 1 +
.../manager/zk/TestAddBuiltInStateModelDef.java | 1 +
.../zk/TestDefaultControllerMsgHandlerFactory.java | 1 +
.../apache/helix/manager/zk/TestRawZkClient.java | 4 +-
.../manager/zk/TestWtCacheAsyncOpMultiThread.java | 1 +
.../manager/zk/TestWtCacheAsyncOpSingleThread.java | 1 +
.../manager/zk/TestWtCacheSyncOpSingleThread.java | 1 +
.../helix/manager/zk/TestZKLiveInstanceData.java | 1 +
.../org/apache/helix/manager/zk/TestZKUtil.java | 6 +-
.../helix/manager/zk/TestZNRecordSerializer.java | 7 +-
.../helix/manager/zk/TestZNRecordSizeLimit.java | 1 +
.../zk/TestZNRecordStreamingSerializer.java | 5 +-
.../helix/manager/zk/TestZkBaseDataAccessor.java | 102 +++++++++-
.../manager/zk/TestZkCacheAsyncOpSingleThread.java | 1 +
.../helix/manager/zk/TestZkClusterManager.java | 1 +
.../apache/helix/manager/zk/TestZkFlapping.java | 1 +
.../apache/helix/manager/zk/TestZkHelixAdmin.java | 1 +
.../apache/helix/manager/zk/TestZkReconnect.java | 1 +
.../serializer/TestJacksonPayloadSerializer.java | 1 +
.../apache/helix/messaging/TestAsyncCallback.java | 1 +
.../helix/messaging/TestAsyncCallbackSvc.java | 1 +
.../messaging/TestDefaultMessagingService.java | 3 +-
.../messaging/handling/MockHelixTaskExecutor.java | 1 +
.../handling/TestBatchMessageModeConfigs.java | 1 +
.../handling/TestConfigThreadpoolSize.java | 3 +-
.../messaging/handling/TestHelixTaskExecutor.java | 3 +-
.../handling/TestResourceThreadpoolSize.java | 1 +
.../messaging/p2pMessage/TestP2PMessages.java | 1 +
.../TestP2PMessagesAvoidDuplicatedMessage.java | 3 +-
.../p2pMessage/TestP2PStateTransitionMessages.java | 3 +-
.../TestP2PWithStateCancellationMessage.java | 4 +-
.../apache/helix/mock/MockBaseDataAccessor.java | 4 +
.../helix/mock/MockClusterMessagingService.java | 1 +
.../java/org/apache/helix/mock/MockHelixAdmin.java | 1 +
.../java/org/apache/helix/mock/MockManager.java | 1 +
.../java/org/apache/helix/mock/MockZkClient.java | 1 +
.../apache/helix/mock/MockZkHelixDataAccessor.java | 1 +
.../mock/controller/MockControllerProcess.java | 1 +
.../helix/mock/participant/ErrTransition.java | 1 +
.../mock/participant/MockHelixTaskExecutor.java | 1 +
.../helix/mock/spectator/MockSpectatorProcess.java | 1 +
.../helix/mock/statemodel/MockTaskStateModel.java | 1 +
.../mock/statemodel/MockTaskStateModelFactory.java | 1 +
.../org/apache/helix/model/TestConstraint.java | 1 +
.../org/apache/helix/model/TestIdealState.java | 1 +
.../apache/helix/model/TestStateModelValidity.java | 3 +-
.../monitoring/TestClusterEventStatusMonitor.java | 1 +
.../TestClusterStatusMonitorLifecycle.java | 8 +-
.../helix/monitoring/TestParticipantMonitor.java | 8 +-
.../helix/monitoring/TestWorkflowMonitor.java | 1 +
.../helix/monitoring/TestZKPathDataDumpTask.java | 1 +
.../mbeans/TestClusterAggregateMetrics.java | 1 +
.../mbeans/TestClusterStatusMonitor.java | 3 +-
.../mbeans/TestDisableResourceMbean.java | 1 +
.../mbeans/TestDropResourceMetricsReset.java | 18 +-
.../mbeans/TestHelixCallbackMonitor.java | 1 +
.../monitoring/mbeans/TestRebalancerMetrics.java | 3 +-
.../monitoring/mbeans/TestResetClusterMetrics.java | 1 +
.../monitoring/mbeans/TestResourceMonitor.java | 1 +
.../mbeans/TestRoutingTableProviderMonitor.java | 14 +-
.../mbeans/TestTaskPerformanceMetrics.java | 26 ++-
.../mbeans/TestTopStateHandoffMetrics.java | 3 +-
.../monitoring/mbeans/TestZkClientMonitor.java | 17 +-
.../helix/participant/MockZKHelixManager.java | 1 +
.../statemachine/TestStateModelParser.java | 1 +
.../helix/spectator/TestRoutingDataCache.java | 45 +++++
.../org/apache/helix/store/TestJsonComparator.java | 1 +
.../store/zk/TestAutoFallbackPropertyStore.java | 1 +
.../helix/store/zk/TestZkHelixPropertyStore.java | 1 +
.../zk/TestZkManagerWithAutoFallbackStore.java | 1 +
.../helix/task/TaskSynchronizedTestBase.java | 1 +
.../helix/task/TestAssignableInstanceManager.java | 1 +
...tAssignableInstanceManagerControllerSwitch.java | 3 +-
.../apache/helix/task/TestCleanExpiredJobs.java | 1 +
.../helix/task/TestDropTerminalTasksUponReset.java | 4 +-
.../task/TestGetLastScheduledTaskExecInfo.java | 99 +++++++---
.../helix/task/TestGetSetUserContentStore.java | 1 +
.../apache/helix/task/TestJobStateOnCreation.java | 3 +-
.../helix/task/TestSemiAutoStateTransition.java | 1 +
.../helix/task/TestTaskCreateThrottling.java | 1 +
.../helix/task/assigner/AssignerTestBase.java | 1 +
.../task/assigner/TestAssignableInstance.java | 1 +
.../assigner/TestThreadCountBasedTaskAssigner.java | 1 +
.../TestStrictMatchExternalViewVerifier.java | 1 +
.../org/apache/helix/tools/TestClusterSetup.java | 1 +
.../helix/tools/TestClusterStateVerifier.java | 3 +-
.../apache/helix/tools/TestClusterVerifier.java | 24 ++-
.../org/apache/helix/tools/TestHelixAdminCli.java | 1 +
.../java/org/apache/helix/tools/TestZkCopy.java | 1 +
.../helix/util/TestIdealStateAssignment.java | 1 +
.../org/apache/helix/util/TestInputLoader.java | 1 +
.../helix/util/TestInstanceValidationUtil.java | 13 +-
.../apache/helix/util/TestRebalanceScheduler.java | 1 +
.../org/apache/helix/util/TestZKClientPool.java | 1 +
.../helix/rest/client/CustomRestClientImpl.java | 7 +-
.../apache/helix/rest/server/HelixRestMain.java | 1 +
.../apache/helix/rest/server/HelixRestServer.java | 1 +
.../apache/helix/rest/server/ServerContext.java | 1 +
.../helix/rest/server/auditlog/AuditLog.java | 1 +
.../helix/rest/server/filters/AuditLogFilter.java | 3 +-
.../rest/server/json/cluster/ClusterInfo.java | 3 +-
.../rest/server/json/cluster/ClusterTopology.java | 4 +-
.../rest/server/json/instance/InstanceInfo.java | 5 +-
.../rest/server/resources/AbstractResource.java | 1 +
.../resources/helix/AbstractHelixResource.java | 1 +
.../server/resources/helix/ClusterAccessor.java | 6 +-
.../server/resources/helix/InstancesAccessor.java | 1 +
.../rest/server/resources/helix/JobAccessor.java | 1 +
.../server/resources/helix/MetadataAccessor.java | 1 +
.../resources/helix/PerInstanceAccessor.java | 26 ++-
.../server/resources/helix/ResourceAccessor.java | 5 +-
.../rest/server/resources/helix/TaskAccessor.java | 1 +
.../server/resources/helix/WorkflowAccessor.java | 1 +
.../resources/metadata/NamespacesAccessor.java | 1 +
.../rest/server/service/ClusterServiceImpl.java | 2 +-
.../helix/rest/server/service/InstanceService.java | 8 +-
.../rest/server/service/InstanceServiceImpl.java | 9 +-
.../helix/rest/client/TestCustomRestClient.java | 12 +-
.../rest/common/TestHelixDataAccessorWrapper.java | 29 ++-
.../helix/rest/server/AbstractTestClass.java | 4 +-
.../helix/rest/server/TestClusterAccessor.java | 6 +-
.../rest/server/TestDefaultMonitoringMbeans.java | 1 -
.../helix/rest/server/TestHelixRestServer.java | 1 +
.../helix/rest/server/TestInstancesAccessor.java | 10 +-
.../apache/helix/rest/server/TestJobAccessor.java | 4 +-
.../helix/rest/server/TestNamespacedAPIAccess.java | 5 +-
.../helix/rest/server/TestPerInstanceAccessor.java | 6 +-
.../helix/rest/server/TestResourceAccessor.java | 4 +-
.../apache/helix/rest/server/TestTaskAccessor.java | 3 +-
.../helix/rest/server/TestWorkflowAccessor.java | 4 +-
.../rest/server/json/cluster/TestClusterInfo.java | 5 +-
.../server/json/cluster/TestClusterTopology.java | 5 +-
.../server/json/instance/TestStoppableCheck.java | 5 +-
.../rest/server/service/TestClusterService.java | 7 +-
.../rest/server/service/TestInstanceService.java | 17 +-
.../rest/server/util/JerseyUriRequestBuilder.java | 6 +-
.../server/util/TestInstanceValidationUtil.java | 4 +-
.../helix/recipes/rabbitmq/ConsumerStateModel.java | 5 +-
.../helix/filestore/FileStoreStateModel.java | 2 +-
.../apache/helix/taskexecution/TaskCluster.java | 2 +-
.../helix/taskexecution/TaskExecutionDemo.java | 4 +-
.../apache/helix/taskexecution/TaskStateModel.java | 7 +-
581 files changed, 2291 insertions(+), 1108 deletions(-)
create mode 100644 helix-core/src/test/java/org/apache/helix/integration/task/TestWorkflowContextWithoutConfig.java