Hi Dan, AFAIK, there is no built-in way to solve your problem. You could check whether state processor API <https://nightlies.apache.org/flink/flink-docs-master/zh/docs/libs/state_processor_api/> could help you. Or you could add log in your program.
Best, Jing Zhang Dan Hill <quietgol...@gmail.com> 于2021年11月26日周五 上午11:00写道： > I'm trying to track down a couple errors I've hit related to key groups. > I want to verify that all of my keys have stable hashes. I tried to print > out the execution plan but it doesn't contain enough info. >
