[streaming] source fault tolerance bug fixes