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 a5cddd4 Update copyright with apache license to pass rat check (#1212)
new 813e49e Fix the flaky test
TestRecurringJobQueue.testCreateStoppedQueue (#983)
new f4cfbc7 Stabilize TestWorkflowTimeout and TestTaskRebalancer (#991)
new ce100d2 Make the task scheduling decision independent of the
PreviousAssignment (#994)
new c122577 Remove previousAssignment in processTaskWithPendingMessage
method (#1040)
new cb8c696 Remove previousAssignment from
FixedTargetTaskAssignmentCalculator (#1061)
new f11243f Remove previousAssignment read/write to ZK (#1074)
new d39b456 Respect Maximum Number Of Attempts for the tasks (#1142)
new 82c4640 Quota calculation based on CurrentState (#1165)
new 3501111 Recover Workflow GC Logic (#1181)
new 5f6d1eb Change the logs to address new changes
The 10 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:
.../apache/helix/common/caches/TaskDataCache.java | 50 +-
.../WorkflowControllerDataProvider.java | 29 +-
.../helix/controller/stages/AttributeName.java | 6 +-
.../controller/stages/CurrentStateOutput.java | 14 +-
.../stages/TaskGarbageCollectionStage.java | 95 +-
.../stages/task/TaskSchedulingStage.java | 8 +
.../java/org/apache/helix/model/IdealState.java | 18 +-
.../apache/helix/task/AbstractTaskDispatcher.java | 234 ++--
.../helix/task/AssignableInstanceManager.java | 172 +++
.../helix/task/DeprecatedTaskRebalancer.java | 1149 --------------------
.../task/FixedTargetTaskAssignmentCalculator.java | 47 +-
.../helix/task/FixedTargetTaskRebalancer.java | 60 -
.../task/GenericTaskAssignmentCalculator.java | 12 +-
.../apache/helix/task/GenericTaskRebalancer.java | 57 -
.../java/org/apache/helix/task/JobDispatcher.java | 113 +-
.../helix/task/TaskAssignmentCalculator.java | 18 +
.../main/java/org/apache/helix/task/TaskUtil.java | 173 +--
.../ThreadCountBasedTaskAssignmentCalculator.java | 10 +
.../org/apache/helix/task/WorkflowDispatcher.java | 19 +-
.../helix/controller/stages/TestTaskStage.java | 89 +-
.../integration/task/TestForceDeleteWorkflow.java | 6 +-
.../integration/task/TestJobQueueCleanUp.java | 18 +-
.../task/TestMaxNumberOfAttemptsMasterSwitch.java | 152 +++
.../integration/task/TestRecurringJobQueue.java | 14 +-
.../helix/integration/task/TestStopWorkflow.java | 6 +-
.../helix/integration/task/TestStuckTaskQuota.java | 189 ++++
.../helix/integration/task/TestTaskRebalancer.java | 14 +-
.../task/TestTaskSchedulingTwoCurrentStates.java | 13 -
.../helix/integration/task/TestTaskStopQueue.java | 10 +-
.../task/TestWorkflowContextWithoutConfig.java | 66 ++
.../integration/task/TestWorkflowTimeout.java | 17 +-
.../helix/task/TestDropTerminalTasksUponReset.java | 3 +-
.../TestFixedTargetedTaskAssignmentCalculator.java | 288 +++++
.../helix/task/TestTargetedTaskStateChange.java | 29 +-
.../java/org/apache/helix/task/TestTaskUtil.java | 95 ++
...eviousAssignedTaskStatusWithPendingMessage.java | 148 +++
36 files changed, 1718 insertions(+), 1723 deletions(-)
delete mode 100644
helix-core/src/main/java/org/apache/helix/task/DeprecatedTaskRebalancer.java
delete mode 100644
helix-core/src/main/java/org/apache/helix/task/FixedTargetTaskRebalancer.java
delete mode 100644
helix-core/src/main/java/org/apache/helix/task/GenericTaskRebalancer.java
create mode 100644
helix-core/src/test/java/org/apache/helix/integration/task/TestMaxNumberOfAttemptsMasterSwitch.java
create mode 100644
helix-core/src/test/java/org/apache/helix/integration/task/TestStuckTaskQuota.java
create mode 100644
helix-core/src/test/java/org/apache/helix/task/TestFixedTargetedTaskAssignmentCalculator.java
create mode 100644
helix-core/src/test/java/org/apache/helix/task/TestTaskUtil.java
create mode 100644
helix-core/src/test/java/org/apache/helix/task/TestUpdatePreviousAssignedTaskStatusWithPendingMessage.java
