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 6EBC9200B92 for ; Tue, 23 Aug 2016 09:45:23 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 6D96D160ABF; Tue, 23 Aug 2016 07:45:23 +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 A8B97160AAD for ; Tue, 23 Aug 2016 09:45:22 +0200 (CEST) Received: (qmail 88453 invoked by uid 500); 23 Aug 2016 07:45:21 -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 88427 invoked by uid 99); 23 Aug 2016 07:45:21 -0000 Received: from arcas.apache.org (HELO arcas) (140.211.11.28) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 23 Aug 2016 07:45:21 +0000 Received: from arcas.apache.org (localhost [127.0.0.1]) by arcas (Postfix) with ESMTP id 923082C0032 for ; Tue, 23 Aug 2016 07:45:21 +0000 (UTC) Date: Tue, 23 Aug 2016 07:45:21 +0000 (UTC) From: "zhangjing (JIRA)" To: dev@flink.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Created] (FLINK-4449) Heartbeat Manager between ResourceManager and TaskExecutor MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 archived-at: Tue, 23 Aug 2016 07:45:23 -0000 zhangjing created FLINK-4449: -------------------------------- Summary: Heartbeat Manager between ResourceManager and TaskExecutor Key: FLINK-4449 URL: https://issues.apache.org/jira/browse/FLINK-4449 Project: Flink Issue Type: Sub-task Components: Cluster Management Reporter: zhangjing Assignee: zhangjing HeartbeatManager is responsible for heartbeat between resourceManager to TaskExecutor 1. Register taskExecutors register heartbeat targets. If the heartbeat response for these targets is not reported in time, mark target failed and notify resourceManager 2. trigger heartbeat trigger heartbeat from resourceManager to TaskExecutor periodically taskExecutor report slot allocation in the heartbeat response ResourceManager sync self slot allocation with the heartbeat response -- This message was sent by Atlassian JIRA (v6.3.4#6332)