Using Flink 1.9.2 with FsStateBackend, Session cluster.
1. Does heap state get cleaned up when a job is cancelled? We have jobs that we run on a daily basis. We start each morning and cancel each evening. We noticed that the process size does not seem to shrink. We are looking at the resident size of the process with ps and also the USED column for Heap on the taskmanager page of the flink dashboard. 1. How can I examine the usage of Flink Managed Memory? The configuration documentation seems to indicate this is used for batch jobs, and we are only using the Streaming API. I reduced taskmanager.memory.fraction to 0.3, but I think this is still reserving too much memory to an area we will not be using.
