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
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
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