changes to make job runnable on current stratosphere-streaming master