public class CoGroupDataSetTest {public static void main(String[] args) throws Exception {ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();//注意：可启用这行代码看区别//env.setParallelism