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

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-13 Thread Martijn Visser
ate: *Wednesday, 12 January 2022 at 7:43 PM > *To: *dev > *Cc: *commun...@flink.apache.org , > user@flink.apache.org , Hang Ruan < > ruanhang1...@gmail.com>, Shrinath Shenoy K (sshenoyk) , > Jayaprakash Kuravatti (jkuravat) , Krishna Singitam > (ksingita) , Nabhonil Sinha (nasinha)