Return-Path: X-Original-To: apmail-flink-user-archive@minotaur.apache.org Delivered-To: apmail-flink-user-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id A968718A7F for ; Mon, 22 Feb 2016 17:00:21 +0000 (UTC) Received: (qmail 30054 invoked by uid 500); 22 Feb 2016 17:00:21 -0000 Delivered-To: apmail-flink-user-archive@flink.apache.org Received: (qmail 29940 invoked by uid 500); 22 Feb 2016 17:00:21 -0000 Mailing-List: contact user-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@flink.apache.org Delivered-To: mailing list user@flink.apache.org Received: (qmail 29923 invoked by uid 99); 22 Feb 2016 17:00:21 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd3-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 22 Feb 2016 17:00:21 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd3-us-west.apache.org (ASF Mail Server at spamd3-us-west.apache.org) with ESMTP id BC44C180AC1 for ; Mon, 22 Feb 2016 17:00:20 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd3-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -2.349 X-Spam-Level: X-Spam-Status: No, score=-2.349 tagged_above=-999 required=6.31 tests=[HTML_MESSAGE=2, KAM_LAZY_DOMAIN_SECURITY=1, RCVD_IN_DNSWL_HI=-5, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, RP_MATCHES_RCVD=-0.329] autolearn=disabled Received: from mx1-lw-us.apache.org ([10.40.0.8]) by localhost (spamd3-us-west.apache.org [10.40.0.10]) (amavisd-new, port 10024) with ESMTP id s-UIeTAfPNLW for ; Mon, 22 Feb 2016 17:00:19 +0000 (UTC) Received: from mail3-relais-sop.national.inria.fr (mail3-relais-sop.national.inria.fr [192.134.164.104]) by mx1-lw-us.apache.org (ASF Mail Server at mx1-lw-us.apache.org) with ESMTPS id 0F6CB5FB15 for ; Mon, 22 Feb 2016 17:00:18 +0000 (UTC) X-IronPort-AV: E=Sophos;i="5.22,485,1449529200"; d="scan'208,217";a="165602279" Received: from ovidcmarcu.irisa.fr ([131.254.17.6]) by mail3-relais-sop.national.inria.fr with ESMTP/TLS/DHE-RSA-AES256-SHA; 22 Feb 2016 18:00:12 +0100 From: Ovidiu-Cristian MARCU Content-Type: multipart/alternative; boundary="Apple-Mail=_224C639B-F0F4-4638-B81B-B7E12A93F8FC" Subject: Batch Processing Fault Tolerance (DataSet API) Message-Id: Date: Mon, 22 Feb 2016 18:00:11 +0100 To: user@flink.apache.org Mime-Version: 1.0 (Mac OS X Mail 9.1 \(3096.5\)) X-Mailer: Apple Mail (2.3096.5) --Apple-Mail=_224C639B-F0F4-4638-B81B-B7E12A93F8FC Content-Transfer-Encoding: quoted-printable Content-Type: text/plain; charset=utf-8 Hi In case of failure of a node what does it mean 'Fault tolerance for = programs in the DataSet API works by retrying failed executions=E2=80=99 = [1] ? -work already done by the rest of the nodes is not lost, only work of = the lost node is recomputed, job execution will continue or -entire job execution is retried [1] = https://ci.apache.org/projects/flink/flink-docs-master/apis/batch/fault_to= lerance.html = Best, Ovidiu=20= --Apple-Mail=_224C639B-F0F4-4638-B81B-B7E12A93F8FC Content-Transfer-Encoding: quoted-printable Content-Type: text/html; charset=utf-8 Hi

In = case of failure of a node what does it mean 'Fault tolerance for = programs in the DataSet API works = by retrying failed executions=E2=80=99 [1] ?

-work already done by the rest of the nodes is not lost, only = work of the lost node is recomputed, job execution will = continue

-entire job = execution is retried

[1] https://ci.apache.org/projects/flink/flink-docs-master/apis/bat= ch/fault_tolerance.html

Best,

Ovidiu

= --Apple-Mail=_224C639B-F0F4-4638-B81B-B7E12A93F8FC--