Benchmarking checkpointing algorithms in Stream Processing Engines