1 个回答
导致原因:
1、节点有性能瓶颈,可能是该节点所在的机器有网络,磁盘等等故障,机器的网络延迟和磁盘不足,频繁GC,数据热点等原因
2、数据源生产的数据过快,计算框架处理不及时。
3、flink算子间并行度不同,下游算子相比上游算子过小
4、发生数据倾斜
发布于:3个月前 (02-06) IP属地:四川省
我来回答
您需要 登录 后回答此问题!