RE: OutOfMemoryError: Java heap space while implmentating flink sql api

2022-01-13 Thread Ronak Beejawat (rbeejawa)
isco.com>>, Arun Yadav (aruny) mailto:ar...@cisco.com>>, Avi Sanwal (asanwal) mailto:asan...@cisco.com>> Subject: Re: OutOfMemoryError: Java heap space while implmentating flink sql api Hi Ronak, I would like to ask you to stop cross-posting to all the Flink mailing lists and

Re: OutOfMemoryError: Java heap space while implmentating flink sql api

2022-01-12 Thread Martijn Visser
Hi Ronak, I would like to ask you to stop cross-posting to all the Flink mailing lists and then also post the same question to Stackoverflow. Both the mailing lists and Stackoverflow are designed for asynchronous communication and you should allow the community some days to address your question.

Re: OutOfMemoryError: Java heap space while implmentating flink sql api

2022-01-12 Thread Roman Khachatryan
Hi Ronak, You shared a screenshot of JM. Do you mean that exception also happens on JM? (I'd rather assume TM). Could you explain the join clause: left join ccmversionsumapTable cvsm ON (cdr.version = cvsm.ccmversion) "version" doesn't sound very selective, so maybe you end up with (almost) Carte

OutOfMemoryError: Java heap space while implmentating flink sql api

2022-01-12 Thread Ronak Beejawat (rbeejawa)
Hi Team, I was trying to implement flink sql api join with 2 tables it is throwing error OutOfMemoryError: Java heap space . PFB screenshot for flink cluster memory details. [Flink Memory Model][1] [1]: https://i.stack.imgur.com/AOnQI.png **PFB below code snippet which I was trying:** ``` E