flink中addSource设置并行度参数

在Flink中，可以通过调用addSource方法来添加数据源。可以通过以下方式设置并行度参数：

1. 在DataStreamSource对象上直接调用setParallelism方法，如下所示：

DataStreamSource<String> source = env.addSource(new MySource());
source.setParallelism(2);

2. 在addSource方法中传递并行度参数，如下所示：

DataStreamSource<String> source = env.addSource(new MySource()).setParallelism(2);

在这两种方式中，都可以设置并行度参数。但是，第一种方式需要对DataStreamSource对象进行额外的操作，而第二种方式则可以直接在addSource方法中设置并行度参数，更加简单方便。