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