[
https://issues.apache.org/jira/browse/HELIX-336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13842276#comment-13842276
]
Hudson commented on HELIX-336:
------------------------------
FAILURE: Integrated in helix #1217 (See
[https://builds.apache.org/job/helix/1217/])
[HELIX-336] Add support for task framework, rb=16071 (zzhang: rev
80fc2be5edace93ad44d878da5f22bf046907806)
* helix-core/src/main/java/org/apache/helix/task/TaskStateModelFactory.java
* helix-core/src/test/java/org/apache/helix/TestZNRecord.java
* helix-core/src/main/java/org/apache/helix/ZNRecord.java
*
helix-core/src/main/java/org/apache/helix/messaging/handling/HelixStateTransitionHandler.java
*
helix-core/src/main/java/org/apache/helix/controller/stages/ExternalViewComputeStage.java
* helix-core/src/main/java/org/apache/helix/tools/StateModelConfigGenerator.java
* helix-core/src/main/java/org/apache/helix/task/TaskDriver.java
* helix-core/src/main/java/org/apache/helix/task/WorkflowContext.java
* helix-core/src/main/java/org/apache/helix/task/TaskRunner.java
*
helix-core/src/test/java/org/apache/helix/integration/task/TestTaskRebalancerStopResume.java
* helix-core/src/main/java/org/apache/helix/tools/ClusterSetup.java
* helix-core/src/main/java/org/apache/helix/model/CurrentState.java
*
helix-core/src/test/java/org/apache/helix/integration/task/TestTaskRebalancer.java
* helix-core/src/main/java/org/apache/helix/task/TaskUtil.java
*
helix-core/src/main/java/org/apache/helix/controller/stages/CurrentStateComputationStage.java
* helix-core/src/main/java/org/apache/helix/task/TaskFactory.java
* helix-core/src/main/java/org/apache/helix/task/TaskContext.java
* helix-core/src/main/java/org/apache/helix/task/beans/WorkflowBean.java
* helix-core/src/main/java/org/apache/helix/task/TaskStateModel.java
* helix-core/src/main/java/org/apache/helix/task/Task.java
*
helix-core/src/main/java/org/apache/helix/participant/statemachine/StateModel.java
* helix-core/src/main/java/org/apache/helix/task/TaskPartitionState.java
*
helix-core/src/main/java/org/apache/helix/messaging/handling/HelixTaskResult.java
* helix-core/src/main/java/org/apache/helix/task/WorkflowConfig.java
* helix-core/src/main/java/org/apache/helix/task/beans/TaskBean.java
* helix-core/src/main/java/org/apache/helix/task/TargetState.java
* helix-core/src/main/java/org/apache/helix/api/accessor/ResourceAccessor.java
* helix-core/src/main/java/org/apache/helix/task/TaskDag.java
* helix-core/src/main/java/org/apache/helix/task/TaskState.java
*
helix-core/src/test/java/org/apache/helix/integration/task/WorkflowGenerator.java
* helix-core/src/main/java/org/apache/helix/task/TaskResult.java
*
helix-core/src/test/java/org/apache/helix/integration/ZkIntegrationTestBase.java
*
helix-core/src/main/java/org/apache/helix/controller/stages/MessageSelectionStage.java
*
helix-core/src/main/java/org/apache/helix/controller/stages/ResourceCurrentState.java
* helix-core/src/test/java/org/apache/helix/integration/task/TestUtil.java
* helix-core/src/main/java/org/apache/helix/task/TaskConstants.java
* helix-core/src/main/java/org/apache/helix/task/TaskRebalancer.java
* helix-core/src/main/java/org/apache/helix/task/TaskConfig.java
* helix-core/src/main/java/org/apache/helix/task/Workflow.java
> Add support for task framework
> ------------------------------
>
> Key: HELIX-336
> URL: https://issues.apache.org/jira/browse/HELIX-336
> Project: Apache Helix
> Issue Type: New Feature
> Reporter: Zhen Zhang
> Assignee: Zhen Zhang
>
> Tasks are partitioned and placed based on a target resource. An explicit set
> of partitions or partition states may also be specified.
> Tasks can be paused, resumed and deleted (the message handlers are still
> being worked on --- for the time being, the test cases directly set zk state).
> Task resources and associated state are expired out of zk after a configured
> amount of time has elapsed since it was created. This is a per-task
> configuration.
> The number of concurrent tasks that run per instance is configurable.
> The only error policy available right now is to fail the entire task if any
> single task partition fails a configured number of times.
> The Task state model is as follows:
> init
> +
> |
> |
> v
> +-------------------+running+------------------------------+
> | + + + |
> | | | | |
> | | | +--------------------+ |
> | | | | |
> | +-----+ +--------+ | |
> v v v v v
> stopped completed timed_out task_error
> error
> + + + + +
> | | | | |
> | +-----+ +--------+ | |
> | | | | |
> | | | +--------------------+ |
> | v v v |
> +------------------> dropped <-----------------------------+
> "init" is the initial state of a task partition.
> "stopped" indicates that task partition is partially done but was stopped by
> the controller.
> "completed" indicates that the task partition is complete.
> "timed_out" indicates that the task partition did not complete within a
> configured time out value.
> "task_error" indicates that the task partition encountered an error during
> execution.
> "error" and "dropped" are helix internal states.
> The "init" to "running" transition does not wait for the task to finish
> execution on the participant. The participant requests state changes (to
> "completed" or "timed_out" or "task_error") via a "REQUESTED_STATE" property
> in the CURRENTSTATE znode.
> If the participant session is reset, all on-going tasks are stopped.
--
This message was sent by Atlassian JIRA
(v6.1#6144)
