Advanced Error Recovery

Design logic to restart stalled or crashed stream pipelines without dropping in-flight data.