Fwd: Replace classes at runtime

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

Fwd: Replace classes at runtime

Jayant Ameta

Jayant Ameta

---------- Forwarded message ----------
From: Jayant Ameta <[hidden email]>
Date: Thu, Dec 14, 2017 at 4:46 PM
Subject: Replace classes at runtime
To: user <[hidden email]>


Hi,
I need to update a few classes of my flink job at runtime. What would be the best way to achieve this? 

Reply | Threaded
Open this post in threaded view
|

Re: Fwd: Replace classes at runtime

Tzu-Li (Gordon) Tai
Hi Jayant,

Updating your job application / operator code at runtime is currently not
available in Flink.
It is however achievable via taking a savepoint of your job, and then
restoring from the savepoint with your upgraded application.

There's a few points to keep in mind, especially job state compatibility, to
allow smooth upgrades.
Please take a look at Upgrading Applications here [1] for more details on
that.

Cheers,
Gordon

[1]
https://ci.apache.org/projects/flink/flink-docs-release-1.4/ops/upgrading.html#restarting-streaming-applications



--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
Reply | Threaded
Open this post in threaded view
|

Re: Fwd: Replace classes at runtime

Jayant Ameta
Hi Gordon,
Is there a way to update the job application without any downtime?

Jayant Ameta

On Tue, Dec 19, 2017 at 12:09 AM, Tzu-Li (Gordon) Tai <[hidden email]> wrote:
Hi Jayant,

Updating your job application / operator code at runtime is currently not
available in Flink.
It is however achievable via taking a savepoint of your job, and then
restoring from the savepoint with your upgraded application.

There's a few points to keep in mind, especially job state compatibility, to
allow smooth upgrades.
Please take a look at Upgrading Applications here [1] for more details on
that.

Cheers,
Gordon

[1]
https://ci.apache.org/projects/flink/flink-docs-release-1.4/ops/upgrading.html#restarting-streaming-applications



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