场景中通过 Flink Stream 消费 Kafka 写入 SR,程序会 OOM,通过内存分析,发现 sink SR 内存一直不释放
OutOfMemoryError: GC overhead limit exceeded
SR 版本:2.5.5.2
Flink: 1.13
SR 主键模型
场景中通过 Flink Stream 消费 Kafka 写入 SR,程序会 OOM,通过内存分析,发现 sink SR 内存一直不释放
OutOfMemoryError: GC overhead limit exceeded
SR 版本:2.5.5.2
Flink: 1.13
SR 主键模型
flink starrocks connector 的版本?是不是该升级了…
1.2.8 也不老吧
还未大量应用,只是一个任务
感觉大概率是写入参数啥的没配置好
starrocks-flink-connector 上面有参数说明的,一般默认即可
但是 flink 需要配置 checkpoint,而且间隔时间需要按照生产的要求来,配置过短,或者没有配置,问题会比较大…
无checkpoint,则可能不会触发 sink event… 也有可能就是这个问题导致的