Submit Flink Job on Yarn cluster to restores its state from it's last savepoint

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

Submit Flink Job on Yarn cluster to restores its state from it's last savepoint

Anil
CONTENTS DELETED
The author has deleted this message.
Reply | Threaded
Open this post in threaded view
|

Re: Submit Flink Job on Yarn cluster to restores its state from it's last savepoint

Till Rohrmann
Hi Anil,

when submitting the job, simply add `bin/flink run --fromSavepoint <savepointPath> -p <parrallelism> <path to flink job>`.

Cheers,
Till

On Fri, Jun 1, 2018 at 4:43 PM, Anil <[hidden email]> 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/