【发布时间】:2020-08-17 04:59:24
【问题描述】:
在重新部署 Flink Stateful Function 时,我找不到任何版本控制问题。
当我为当前正在执行的实例的有状态函数更新和部署代码时,会产生什么影响:
- 当前正在执行的实例,不等待回调?
- 当前正在等待异步回调的实例(运行什么代码 回调何时返回)?
- 如果其中一个或 1 或 2 可能正在执行新代码,如何处理旧版本和新执行版本之间 2 个函数版本的可能不同的持久状态?
- 如果2没有自动升级,如何导致新功能版本运行 当我想让这发生很长时间时 运行函数(假设它正在等待 30 天的自我回调 计时器,我希望新版本在回调时执行 返回)?如果我可以升级版本,那么处理版本之间可能添加或删除持久状态的方法是什么?
【问题讨论】:
标签: flink-statefun