I'm working on writing a test for my Flink system. I want to pump data through my topology, query the state, and then reset my test. Are there any management capabilities for Queryable state such as the ability to reset/delete current state so that I can clear my state between test runs? I haven't found any in the docs, but I'm hoping I just missed something. Thanks.
1 Answers
Related