
1.场景1
1.1 概述
一个flink任务报错 如下

Failed to allocate.memory within the configed max blocking time
kafka在规定的时间内没有分配到内存。
内存不足:解决方法:
#修改kafka-server-start.sh
export KAFKA_HEAP_OPTS="-Xmx1G -Xms1G"
修改为
export KAFKA_HEAP_OPTS="-Xmx256M -Xms128M"
或者 调大yarn任务内存,机器内存等。