[streaming] DataStream merge fix + example clean-up