Return-Path: X-Original-To: apmail-helix-commits-archive@minotaur.apache.org Delivered-To: apmail-helix-commits-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 66FFD10C86 for ; Fri, 6 Dec 2013 01:16:01 +0000 (UTC) Received: (qmail 39205 invoked by uid 500); 6 Dec 2013 01:16:01 -0000 Delivered-To: apmail-helix-commits-archive@helix.apache.org Received: (qmail 39133 invoked by uid 500); 6 Dec 2013 01:16:01 -0000 Mailing-List: contact commits-help@helix.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@helix.incubator.apache.org Delivered-To: mailing list commits@helix.incubator.apache.org Received: (qmail 39107 invoked by uid 99); 6 Dec 2013 01:16:00 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 06 Dec 2013 01:16:00 +0000 X-ASF-Spam-Status: No, hits=-2000.0 required=5.0 tests=ALL_TRUSTED,RP_MATCHES_RCVD X-Spam-Check-By: apache.org Received: from [140.211.11.3] (HELO mail.apache.org) (140.211.11.3) by apache.org (qpsmtpd/0.29) with SMTP; Fri, 06 Dec 2013 01:15:57 +0000 Received: (qmail 38455 invoked by uid 99); 6 Dec 2013 01:15:36 -0000 Received: from arcas.apache.org (HELO arcas.apache.org) (140.211.11.28) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 06 Dec 2013 01:15:36 +0000 Date: Fri, 6 Dec 2013 01:15:36 +0000 (UTC) From: "Zhen Zhang (JIRA)" To: commits@helix.incubator.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Updated] (HELIX-336) Add support for task framework MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 X-Virus-Checked: Checked by ClamAV on apache.org [ https://issues.apache.org/jira/browse/HELIX-336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhen Zhang updated HELIX-336: ----------------------------- Environment: (was: 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.) > 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 > -- This message was sent by Atlassian JIRA (v6.1#6144)