Dear All, I am trying to figure how Flink is managing the memory. I found this link: https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=53741525 <https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=53741525>
Question 1 - If, in my code, I defined two objects, one is native Java HashMap, one is the Flink MapState, which part of the JVM heap, as mentioned in above figure, each of them is put? Are both Java HashMap and Flink MapState are put in Free or Memory Manager? Question 2 - As it is stated in the doc, TaskManager allocates the memory on start-up time (lets say 1024MB). Does that mean, if I check the utilization of the memory on the machine (i.e., via top), these allocated memory is in used? It does not matter whether I have jobs running on the TaskManager? Lets say, if I start or stop a simple job, the memory usage will the same (if there is not off-heap memory used or there is no OOM)? Many Thanks. Best regards/祝好, Chang Liu 刘畅
