helix-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From j...@apache.org
Subject [helix] branch helix-cloud updated (eb6ee21 -> 9280f22)
Date Sat, 07 Dec 2019 01:26:51 GMT
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


Mime
View raw message