[streaming] source fault tolerance bugfix wip 2