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 c98dfa0 improve unstable test TestResourceThreadpoolSize
new 4561496 [HELIX-792] HELIX: fix typo in WorkflowDataProvider
new 2f22df6 [HELIX-793] TASK: Make TaskAssigner honor instance
constraints Previously, ThreadCountBasedTaskAssigner was assigning to all
AssignableInstances. This could potentially be problematic because some users
may wish to use InstanceGroupTags, in which case we must filter out instances
that do not have the appropriate tags. This RB adds a logic that helps
TaskAssigner honor such constraints.
new ddb3690 [HELIX-794] TASK: Fix double-booking of tasks upon
Participant disconnect
new f9f89a7 [HELIX-795] TASK: Drop tasks upon Participant reconnect
new 4cd7269 [HELIX-796] HELIX: Add fields to MaintenanceSignal
The 5 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:
.../WorkflowControllerDataProvider.java | 4 +-
.../helix/manager/zk/CurStateCarryOverUpdater.java | 18 ++-
.../org/apache/helix/model/MaintenanceSignal.java | 70 +++++++++
.../helix/participant/HelixStateMachineEngine.java | 16 +-
.../apache/helix/task/AbstractTaskDispatcher.java | 38 +++--
.../helix/task/AssignableInstanceManager.java | 10 ++
.../java/org/apache/helix/task/JobDispatcher.java | 48 ++++--
.../java/org/apache/helix/task/TaskStateModel.java | 13 +-
.../ThreadCountBasedTaskAssignmentCalculator.java | 2 +-
.../apache/helix/task/assigner/TaskAssigner.java | 4 +-
.../assigner/ThreadCountBasedTaskAssigner.java | 14 +-
.../task/TestDropOnParticipantReset.java | 95 ++++++++++++
.../helix/integration/task/TestNoDoubleAssign.java | 171 +++++++++++++++++++++
.../assigner/TestThreadCountBasedTaskAssigner.java | 67 ++++++--
14 files changed, 512 insertions(+), 58 deletions(-)
create mode 100644
helix-core/src/test/java/org/apache/helix/integration/task/TestDropOnParticipantReset.java
create mode 100644
helix-core/src/test/java/org/apache/helix/integration/task/TestNoDoubleAssign.java
