[streaming] fault tolerance bugfixes and added FailEvent wip