流处理并行度分区限制

流处理作业的并行子任务数受限于分区数量，想提升并行度先看数据源分区够不够，这是实时计算调优的第一道闸门，为什么流处理作业的并行子任务数为什么受限于分区数量流处理作业的并行子任务数，本质上就是同一个算子被复制成几份同时跑，每份子任务要拿到属于自己的输入数据，数据从哪来？多数来自 Kafka、Pulsar、Rock……