[streaming] fault tolerance test wip2