【详述】flink消费kafka写starrocks报错
【背景】正常写入一天后突然报错
【业务影响】 无法正常启动flink任务,消费积压
【StarRocks版本】例如:2.2.7
【集群规模】1fe+3be
【机器信息】CPU虚拟核/内存/网卡,例如:56C/256G/万兆
【附件】
bewarn日志:
内存cpu监控:
flink sink配置参数:
be conf已新增配置并重启:
【详述】flink消费kafka写starrocks报错
【背景】正常写入一天后突然报错
【业务影响】 无法正常启动flink任务,消费积压
【StarRocks版本】例如:2.2.7
【集群规模】1fe+3be
【机器信息】CPU虚拟核/内存/网卡,例如:56C/256G/万兆
【附件】
bewarn日志:
内存cpu监控:
flink sink配置参数:
be conf已新增配置并重启:
这是导入频率太高导致的,可以在flink日志中搜下_stream_load,看下每次触发sink的时候是满足哪个田间触发的?