apache-flink - Apache 弗林克 : How can I reload an updated jar without restarting my job?

Question

我的 Flink 作业有一个客户端提供的 jar 文件，我可以将其存储在/lib 文件夹中。有没有办法在不重启集群的情况下重新加载更新后的 jar 文件？

Answer 1

不，当前版本(Flink 1.4.0，2017 年 12 月)无法做到这一点。

Flink 提供 savepoints保存应用程序的状态。如果您想更改应用程序的代码(或依赖项)，则必须获取一个保存点，更新代码/依赖项，然后从保存点重新启动应用程序。

此技术还可用于扩展或缩小应用程序或迁移应用程序。