apache-flink - 重置可查询状态

Question

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

Answer 1

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

您可以做的是在您的流中注入(inject)一个特殊事件，该事件会被您的运算符(operator)检测到，并在收到后清除状态。