Flink-更改规则添加/更新/删除SQL查询

问题描述

我的flink应用程序具有作为SQL查询的规则，并且具有一个输入事件源。 SQL查询在传入事件上运行/评估，一旦条件匹配，我的应用程序就会触发该事件。

问题是：

1. 如果存在添加/删除/更新规则（SQL查询）的运行时要求，如何处理方案？

如果我为每个SQL查询分配UUID，

2. 将在保存点句柄添加/更新/删除方案下重新启动吗？

3. 如果使用保存点句柄重新启动，那么我们是否需要重新启动整个集群或仅重新启动jobmanager或taskmanager？

感谢您对此的帮助/建议。

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）