在规则(add/update/delete)sql查询中更改

lskq00tm  于 2021-06-21  发布在  Flink
关注(0)|答案(0)|浏览(224)

我的flink应用程序有sql查询规则,它有一个输入事件源。sql查询在传入事件上运行/计算,一旦条件与我的应用程序匹配,就会触发事件。
问题是:
如果运行时需要添加/删除/更新规则(sql查询),如何处理该场景?
如果我将uuid分配给每个sql查询,是否将使用保存点句柄add/update/delete场景重新启动?
如果用保存点句柄重新启动,那么我们需要重新启动整个集群还是只重新启动jobmanager或taskmanager?
感谢你在这方面的帮助/建议。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题