Unrelated, but another question. Is there a way to determine the size of state by operator-uid for a given job? I’m currently working with a job that’s doing quite of bit of enrichment and the keying step of there is causing some hotspotting. The state is all currently backed by RocksDB/keyed state but if I could get a reasonable estimate of the size, it may be something that could be handled via Broadcast state and the existing keying could be removed.
Is it possible to determine this through checkpoints/savepoints? I know at one point the Flink REST API could expose similar information, just trying to gauge where the best place to get that info would be (if possible at all).