看下 Flink 任务运行,是否是其他机器上的资源先达到瓶颈，而不是 CPU，比如 IO，同时看下你的 flatmap 处理单条记录的时间。 同时也参考上面同学的，是否存在反压，如果 flatmap 逻辑比较复杂，也有这个可能。
Best, LakeShen 赵一旦 <hinobl...@gmail.com> 于2021年1月5日周二 下午9:13写道： > > 可以看看是否反压。反压说明并行度还是不够，不反压的话看处理速度是否符合预期。符合预期就不用调了，说明你的任务不复杂，那点cpu占用就够了。如果不符合预期，也没有任何反压，那就是source消费速度太慢。 > > > > housezhang <zhanghao8...@gmail.com> 于2021年1月5日周二 下午5:44写道： > > > 有可能是cpu能够处理得过来，网络io处理不过来了，看看网络使用情况 > > > > > > > > -- > > Sent from: http://apache-flink.147419.n8.nabble.com/ >
