然后我们再来测试一下,之前我们设置的并行度,可以看到都是1对吧,

现在我们把这个env.setParallelism(1)这个删除掉.

现在我们机器的核心是4核心,所以现在并行度就是4了.

然后我们去看看准备的数据,我们去掉,并行度为1 的,代码以后,我们再去测试一下看

这里,我们看看,如果,数据来源,是来至两个分区,也就是两个slot,两个任务的话,一个任务,

发送sensor_1这个数据,一个任务发送sensor_6这个数据,这个