Apache Flink 状态函数远程模块更新



如何动态更新module.yaml?例如,我想添加新的远程函数,所以我必须更新 module.yaml 文件。我应该停止/启动 flink 集群来更新 module.yaml 吗?什么是真正的用例方法?更新或现有的远程功能作业很好。因为滚动更新就足够了。

目前,修改 module.yaml 的方法是重新启动 Flink 集群,但有状态函数社区正在努力在未来的版本中消除该限制。

相关内容

  • 没有找到相关文章

最新更新