added a job-tag
stream_sink -> text_sink
wrapped_sink removed