Re: OOM error behaviour change in newer version

2023-04-06 Thread Shammon FY
Hi neha I think you can compare the detailed information about memory usage or error messages. You can also dump heap memory to analyse the objects with some tools for the two versions of flink Best, Shammon FY On Thu, Apr 6, 2023 at 9:58 PM neha goyal wrote: > Hello, > I want to understand th

Re: flink-operator: jarURI seems mandatory

2023-04-06 Thread David Causse
Hi Weihua, Thanks for your reply! Even when I use jarURI: "local:///path/to/job.jar" I can see that the classes loaded by the taskmanager are from something like: file:/tmp/tm_flink-app-wdqs-taskmanager-1-10/blobStorage/job_94ec61137dc8814f4558116848dd29cc/blob_p-0037843784c2e3ee289c9cc3ec644bc0

OOM error behaviour change in newer version

2023-04-06 Thread neha goyal
Hello, I want to understand the reason behind the different behavior of Flink-delta pipelines. When I am running a Kafka in and delta out pipeline with fewer resources than needed for a particular pipeline, It fails with an OOM error. In the newer version, it takes around 8 minutes to give the firs