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