重置可查询状态

Question

我正在为我的Flink系统编写测试。我想通过拓扑抽取数据，查询状态，然后重置我的测试。是否有可查询状态的管理功能，如重置/删除当前状态的能力，以便我可以在测试运行之间清除状态？我没有在文档中找到任何内容，但我希望我错过了一些东西。谢谢。

Answer 1

Flink的可查询状态客户端只允许您读取状态。写入路径是在拓扑中流动的数据。因此，目前有使用可查询状态客户端写入状态信息的方法。

您可以做的是在您的操作员检测到的流中注入一个特殊事件，并在接收到该事件后清除状态。