我的Flink作业有一个由客户端提供的jar文件,我可以将其存储在/lib文件夹中。有没有办法在不重启集群的情况下重新加载更新后的jar文件?
发布于 2017-12-15 15:45:48
不,对于当前版本(Flink 1.4.0,2017年12月),这是不可能的。
Flink提供了savepoints来保存应用程序的状态。如果您想要更改应用程序的代码(或依赖项),您必须获取一个保存点,更新代码/依赖项,然后从保存点重新启动应用程序。
此技术还可用于扩展或缩小应用程序或迁移应用程序。
https://stackoverflow.com/questions/47825611
复制相似问题