Correct (hopefully) error handling at one stream processing level