重置可查詢狀態

Question

我正在爲我的Flink系統編寫測試。我想通過拓撲抽取數據，查詢狀態，然後重置我的測試。是否有可查詢狀態的管理功能，如重置/刪除當前狀態的能力，以便我可以在測試運行之間清除狀態？我沒有在文檔中找到任何內容，但我希望我錯過了一些東西。謝謝。

Answer 1

Flink的可查詢狀態客戶端只允許您讀取狀態。寫入路徑是在拓撲中流動的數據。因此，目前有使用可查詢狀態客戶端寫入狀態信息的方法。

您可以做的是在您的操作員檢測到的流中注入一個特殊事件，並在接收到該事件後清除狀態。