Apache Flink：如何在不重新启动工作的情况下重新加载更新的 jar？

Question

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

Answer 1

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

Flink 提供 savepoints 来保存应用程序的状态。 如果要更改应用程序的代码（或依赖项），则必须获取保存点，更新 code/dependencies，然后从保存点重新启动应用程序。

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