Accommodating bursts in distributed stream processing systems