From user-return-20302-archive-asf-public=cust-asf.ponee.io@flink.apache.org Fri Jun 1 17:45:05 2018 Return-Path: X-Original-To: archive-asf-public@cust-asf.ponee.io Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx-eu-01.ponee.io (Postfix) with SMTP id 1828A18063A for ; Fri, 1 Jun 2018 17:45:04 +0200 (CEST) Received: (qmail 36632 invoked by uid 500); 1 Jun 2018 15:45:03 -0000 Mailing-List: contact user-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Delivered-To: mailing list user@flink.apache.org Received: (qmail 36623 invoked by uid 99); 1 Jun 2018 15:45:03 -0000 Received: from mail-relay.apache.org (HELO mailrelay2-lw-us.apache.org) (207.244.88.137) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 01 Jun 2018 15:45:03 +0000 Received: from mail-qk0-f178.google.com (mail-qk0-f178.google.com [209.85.220.178]) by mailrelay2-lw-us.apache.org (ASF Mail Server at mailrelay2-lw-us.apache.org) with ESMTPSA id 0BB2B29EA for ; Fri, 1 Jun 2018 15:45:02 +0000 (UTC) Received: by mail-qk0-f178.google.com with SMTP id y4-v6so2031170qka.5 for ; Fri, 01 Jun 2018 08:45:02 -0700 (PDT) X-Gm-Message-State: APt69E3u9MzZIxqH/aVEynvFY9r+BIrtlwmbD8lv4KRyK4Pe5EFhbhHm W/yc5lanlLBmjiYHNqyuOrT5R6WfnsiA8yxEpFE= X-Google-Smtp-Source: ADUXVKIoh6jWb6l8Kxqdvu6Qr4D9rbMbGGK/5/6WgeK7vsypLs2IxXrD8iyamg0b/b9fOVOUjHRPG1ichJjMWZNcZZ8= X-Received: by 2002:a37:7b86:: with SMTP id w128-v6mr10524510qkc.15.1527867902101; Fri, 01 Jun 2018 08:45:02 -0700 (PDT) MIME-Version: 1.0 Received: by 2002:a0c:8190:0:0:0:0:0 with HTTP; Fri, 1 Jun 2018 08:44:21 -0700 (PDT) In-Reply-To: <1527864187759-0.post@n4.nabble.com> References: <1527864187759-0.post@n4.nabble.com> From: Till Rohrmann Date: Fri, 1 Jun 2018 17:44:21 +0200 X-Gmail-Original-Message-ID: Message-ID: Subject: Re: Submit Flink Job on Yarn cluster to restores its state from it's last savepoint To: Anil Cc: user Content-Type: multipart/alternative; boundary="000000000000918dbc056d9677c9" --000000000000918dbc056d9677c9 Content-Type: text/plain; charset="UTF-8" Hi Anil, when submitting the job, simply add `bin/flink run --fromSavepoint -p `. Cheers, Till On Fri, Jun 1, 2018 at 4:43 PM, Anil wrote: > I am running these Flink job in a Yarn cluster. When the flink job fails > or I > restart it I want the Flink job to use the savepoint that was created > before > it restarted. How do can restart the Flink job with this savepoint. I am > using Flink 1.4.2. > > > > -- > Sent from: http://apache-flink-user-mailing-list-archive.2336050. > n4.nabble.com/ > --000000000000918dbc056d9677c9 Content-Type: text/html; charset="UTF-8" Content-Transfer-Encoding: quoted-printable
Hi Anil,

when submitting the job, simpl= y add `bin/flink run --fromSavepoint <savepointPath> -p <parrallel= ism> <path to flink job>`.

Cheers,
<= div>Till

On Fri, Jun 1, 2018 at 4:43 PM, Anil <anilsingh.jsr@gmail.com= > wrote:
I am running these Fli= nk job in a Yarn cluster. When the flink job fails or I
restart it I want the Flink job to use the savepoint that was created befor= e
it restarted. How do can restart the Flink job with this savepoint. I am using Flink 1.4.2.



--
Sent from: http://apache-flink-u= ser-mailing-list-archive.2336050.n4.nabble.com/

--000000000000918dbc056d9677c9--