Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id BA36D200C22 for ; Tue, 21 Feb 2017 11:42:48 +0100 (CET) Received: by cust-asf.ponee.io (Postfix) id B8D77160B3E; Tue, 21 Feb 2017 10:42:48 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 0CCC0160B68 for ; Tue, 21 Feb 2017 11:42:47 +0100 (CET) Received: (qmail 93470 invoked by uid 500); 21 Feb 2017 10:42:47 -0000 Mailing-List: contact dev-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@flink.apache.org Delivered-To: mailing list dev@flink.apache.org Received: (qmail 93458 invoked by uid 99); 21 Feb 2017 10:42:47 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd4-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 21 Feb 2017 10:42:47 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd4-us-west.apache.org (ASF Mail Server at spamd4-us-west.apache.org) with ESMTP id AF7BCC0258 for ; Tue, 21 Feb 2017 10:42:46 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd4-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -1.999 X-Spam-Level: X-Spam-Status: No, score=-1.999 tagged_above=-999 required=6.31 tests=[KAM_LAZY_DOMAIN_SECURITY=1, RP_MATCHES_RCVD=-2.999] autolearn=disabled Received: from mx1-lw-eu.apache.org ([10.40.0.8]) by localhost (spamd4-us-west.apache.org [10.40.0.11]) (amavisd-new, port 10024) with ESMTP id fsvHGCc52R73 for ; Tue, 21 Feb 2017 10:42:46 +0000 (UTC) Received: from mailrelay1-us-west.apache.org (mailrelay1-us-west.apache.org [209.188.14.139]) by mx1-lw-eu.apache.org (ASF Mail Server at mx1-lw-eu.apache.org) with ESMTP id 7F54C5F4A8 for ; Tue, 21 Feb 2017 10:42:45 +0000 (UTC) Received: from jira-lw-us.apache.org (unknown [207.244.88.139]) by mailrelay1-us-west.apache.org (ASF Mail Server at mailrelay1-us-west.apache.org) with ESMTP id 50ED8E00D6 for ; Tue, 21 Feb 2017 10:42:44 +0000 (UTC) Received: from jira-lw-us.apache.org (localhost [127.0.0.1]) by jira-lw-us.apache.org (ASF Mail Server at jira-lw-us.apache.org) with ESMTP id 0BC4B2411F for ; Tue, 21 Feb 2017 10:42:44 +0000 (UTC) Date: Tue, 21 Feb 2017 10:42:44 +0000 (UTC) From: "shuai.xu (JIRA)" To: dev@flink.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Created] (FLINK-5866) The implementation of FailoverRegion. MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 archived-at: Tue, 21 Feb 2017 10:42:48 -0000 shuai.xu created FLINK-5866: ------------------------------- Summary: The implementation of FailoverRegion. Key: FLINK-5866 URL: https://issues.apache.org/jira/browse/FLINK-5866 Project: Flink Issue Type: Sub-task Components: JobManager Reporter: shuai.xu Assignee: shuai.xu In flip1, FailoverRegion will manage the failover of a minimal pipelined conncected executions. One job graph may has several FailoverRegions and they will be calculated statically after job graph is attached. FailoverRegion has serval states, CREATED, CANCELING, CANCELED, RUNNING, it will transforms its state according to the state of the ExectionVertexes it contains and drives the failover during state transformation. A FailoverRegion may have preceding and succeeding FailoverRegions. It will wait for its preceding ones and notice its succeeding ones when finishing. -- This message was sent by Atlassian JIRA (v6.3.15#6346)