I am pretty new to flink and have an initial streaming job working both locally 
and remotely.  But, both ways if the data volume is too high it runs out of 
heap.  I am using RichMapFunction to process multiple streams of data.  I 
assumed Flink would manage keeping state in ram when possible, and spill to 
RocksDB when it exceeded heap.

Is this correct?  If so are there configs I need to set to enable or tune this 
so it can run within a fixed memory size?


Reply via email to