Hi All,

I have a flink job with RMQ Source, filters, tumbling window(uses
processing time fires every 2s), aggregator, RMQ Sink.

I am trying to understand about states and checkpoints(enabled incremental
rocksdb checkpoints).

In local rocks db directory, I have .sst files, log, lock, options files.

I read that states are cleared once tumbling window is fired. Does it mean
my local rocksdb directory's .sst files will be deleted once windows
fires??.

Happy Learning. Happy Weekend.

Thanks
Banu

Reply via email to