Thanks Dawid. As I see in the code the buffered storage in between watermarks is stored in /MapState<Long, List<IN>> elementQueueState /variable in /class CepOperator/. My question is, if we use rocksDb or some other state backend then would this state be stored on that and checkpointed ? or is it always in the heap for faster access ? Also since this storage is between the watermarks, in a high volume application a watermarking strategy becomes important, is that correct assumption ?
-- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
