全部面试刷题微服务数据库消息队列搜索引擎大数据运维 go语言人工智能

如何解决FlinkSQL作业中"数据堆积"问题？

提问者：帅平问题分类：面试刷题

FlinkSQL面试题 Flink

发布于：4天前 IP属地：

1 个回答

素手烹茶べ待君归

可以采取的措施有：

1、增加并行度：若数据源为Kafka，增加消费者数量（consumer.parallelism）或分区数（topic.partitions）。
2、调整拉取批次大小：增大fetch.min.bytes和fetch.max.wait.ms，减少频繁拉取。
3、根据CPU核心数调整默认并行度（通常设为物理核数的2~4倍）。
4、对高负载算子（如窗口聚合）单独设置更高并行度
5、增加TaskManager内存，避免OOM

发布于：4天前 IP属地：

我来回答