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/