[streaming] starting Storm-style fault tolerance