setParallelism added for datastream operators to match main project