Re: Flink restarts after hitting outOfMemory

2022-02-14 Thread Caizhi Weng
Hi! Heap memory usage depends heavily on your job and your state backend. Which state backend are you using and if possible could you share your user code or explain what operations your job is doing? Misha Hungyo 于2022年2月14日周一 16:56写道: > Hi, > I have a flink job that runs continuously(the job

Flink restarts after hitting outOfMemory

2022-02-14 Thread Misha Hungyo
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 th