There are evidence that attributes being passed to the source were not being passed on correctly to the source of the partition sub-stream. A failing sub-stream did not use the same supervisor directive as the parent stream. This was observed when OnDeserializationError was used to log bad messages and the decider was supposed to use Directive.Resume instead of stop.