osdir.com

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Flink memory management in table api


Hello folks,

I am using flink table api to join multiple tables and create a single
table from them. I have some doubts in my mind.

1. How long the query will maintain partial results per key and how it
maintains state of each key?

2. If it is maintains state in memory then the memory will continuously
grows and it leads to memory over head.

3. How much RAM server  needs to handle 10,000 per seconds incoming records
of average size of 3KB.

-----------------------------------------------
*Amol Suryawanshi*
Java Developer
amols@xxxxxxxxxxxxxxx


*iProgrammer Solutions Pvt. Ltd.*



*Office 103, 104, 1st Floor Pride Portal,Shivaji Housing Society,
Bahiratwadi,Near Hotel JW Marriott, Off Senapati Bapat Road, Pune - 411016,
MH, INDIA.**Phone: +91 9689077510 | Skype: amols_iprogrammer*
www.iprogrammer.com <sachin@xxxxxxxxxxxxxxx>
------------------------------------------------