gpt4 book ai didi

apache-flink - 重置可查询状态

转载 作者:行者123 更新时间:2023-12-04 05:13:02 24 4
gpt4 key购买 nike

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

最佳答案

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

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

关于apache-flink - 重置可查询状态,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/44230054/

24 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com