I have a flink job with Rabbitmq source,keyby, tumbling window and aggregator function, sink.
I’m using rockDB state backend along with incremental checkpoints. Every 10s checkpointing is happening with 5s pause between checkpoints.