我的flink作业有一个客户机提供的jar文件,我可以将其存储在/lib文件夹中。有没有办法在不重新启动集群的情况下重新加载更新后的jar文件?
q3qa4bjr1#
不,这在当前版本中是不可能的(flink 1.4.0,2017年12月)。flink提供保存点来保存应用程序的状态。如果要更改应用程序的代码(或依赖项),zou必须获取保存点,更新代码/依赖项,然后从保存点重新启动应用程序。此技术还可用于向上或向下扩展应用程序或迁移应用程序。
1条答案
按热度按时间q3qa4bjr1#
不,这在当前版本中是不可能的(flink 1.4.0,2017年12月)。
flink提供保存点来保存应用程序的状态。如果要更改应用程序的代码(或依赖项),zou必须获取保存点,更新代码/依赖项,然后从保存点重新启动应用程序。
此技术还可用于向上或向下扩展应用程序或迁移应用程序。