You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@helix.apache.org by al...@apache.org on 2020/09/14 21:51:26 UTC

[helix] branch master updated (35ac0ff -> 027481f)

This is an automated email from the ASF dual-hosted git repository.

alizamus pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/helix.git.


    from 35ac0ff  Enhance ZkHelixVerifier and its related subclass to take a default wait period (#1328)
     add 027481f  Task Framework IdealState Removal (#1326)

No new revisions were added by this update.

Summary of changes:
 .../stages/ResourceComputationStage.java           | 141 +++++++++++++++++----
 .../stages/task/TaskSchedulingStage.java           | 118 +----------------
 .../apache/helix/task/AbstractTaskDispatcher.java  |  11 ++
 .../java/org/apache/helix/task/JobDispatcher.java  |  10 +-
 .../java/org/apache/helix/task/TaskDriver.java     |  43 +------
 .../main/java/org/apache/helix/task/TaskUtil.java  |   6 +
 .../org/apache/helix/task/WorkflowDispatcher.java  |  96 +++++---------
 .../assigner/ThreadCountBasedTaskAssigner.java     |  27 +---
 .../TestQuotaConstraintSkipWorkflowAssignment.java |   5 +-
 .../helix/controller/stages/TestTaskStage.java     |  35 ++---
 .../task/TestCurrentStateDropWithoutConfigs.java   |  62 +++++++++
 .../task/TestDeleteJobFromJobQueue.java            |   4 -
 .../helix/integration/task/TestDeleteWorkflow.java |  32 ++---
 .../integration/task/TestForceDeleteWorkflow.java  |  45 +++----
 .../task/TestJobQueueDeleteIdealState.java         |  99 ---------------
 .../task/TestTaskRebalancerParallel.java           |   5 +-
 .../task/TestWorkflowContextWithoutConfig.java     |  75 +----------
 .../task/TestGetLastScheduledTaskExecInfo.java     |   4 +
 18 files changed, 287 insertions(+), 531 deletions(-)
 create mode 100644 helix-core/src/test/java/org/apache/helix/integration/task/TestCurrentStateDropWithoutConfigs.java
 delete mode 100644 helix-core/src/test/java/org/apache/helix/integration/task/TestJobQueueDeleteIdealState.java