我正在为我的 Flink 系统编写一个测试。 我想通过拓扑抽取数据,查询状态,然后重置测试。 是否有任何可查询状态的管理功能,例如重置/删除当前状态的功能,以便我可以在测试运行之间清除状态? 我在文档中没有找到任何内容,但我希望我只是错过了一些东西。 谢谢。
Flink 的可查询状态客户端只允许你读取状态。写入路径是在拓扑中流动的数据。因此,目前有办法使用可查询状态客户端来写入状态信息。
您可以做的是在流中注入一个特殊事件,该事件由操作员检测到,并在收到后清除状态。