Apache Flink:如何在不重新启动工作的情况下重新加载更新的罐子



我的flink作业有一个客户提供的jar文件,我可以将其存储在/lib文件夹中。有没有一种方法可以重新加载更新的JAR文件,而无需重新启动群集?

否,当前版本是不可能的(Flink 1.4.0,2017年12月)。

Flink提供保存点以保存应用程序状态的保存点。如果要更改应用程序的代码(或依赖关系),则Zou必须采用保存点,更新代码/依赖项,并从SavePoint重新启动应用程序。

此技术也可以用于向上或向下缩放应用程序或迁移。

最新更新