Hi, Getting the below OOM but the job failed 4-5 times and recovered from there.
j *ava.lang.Exception: java.lang.OutOfMemoryError: GC overhead limit exceeded at org.apache.flink.streaming.runtime.tasks.SourceStreamTask$LegacySourceFunctionThread.checkThrowSourceExecutionException(SourceStreamTask.java:212) at org.apache.flink.streaming.runtime.tasks.SourceStreamTask.performDefaultAction(SourceStreamTask.java:132) at org.apache.flink.streaming.runtime.tasks.StreamTask.run(StreamTask.java:298) at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:403) at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:705) at org.apache.flink.runtime.taskmanager.Task.run(Task.java:530) at java.lang.Thread.run(Thread.java:748)Caused by: java.lang.OutOfMemoryError: GC overhead limit exceeded* Is there any way I can debug this. since the job after a few re-starts started running fine. what could be the reason behind this. Thanks, Hemant