move ExceptionGenerator from beginJob to beginStream (since it's now a stream module)