Hi, I have a flink job that runs continuously(the job never goes to* FINISHED* state but is always in *RUNNING* state) and there are stateful operations too. But the states are cleared after the time threshold is hit. Logically, from what I understand, the memory claimed should be cleaned up but this doesn't seem to happen. After few hours, the taskmanager throws the OutOfMemoryError and jobmanager restarts.
How can I improve or solve this issue? -- Misha Hungyo R&D Nokia Networks
