Flink Stream 消费Kafka sink SR OOM

场景中通过 Flink Stream 消费 Kafka 写入 SR,程序会 OOM,通过内存分析,发现 sink SR 内存一直不释放
OutOfMemoryError: GC overhead limit exceeded

SR 版本:2.5.5.2
Flink: 1.13

SR 主键模型

flink starrocks connector 的版本?是不是该升级了… :smiley_cat:

1.2.8 也不老吧 :smile:

是每个任务都这样,还是其中一个?

还未大量应用,只是一个任务

感觉大概率是写入参数啥的没配置好

有哪些参数可以优化

starrocks-flink-connector 上面有参数说明的,一般默认即可

但是 flink 需要配置 checkpoint,而且间隔时间需要按照生产的要求来,配置过短,或者没有配置,问题会比较大…

无checkpoint,则可能不会触发 sink event… 也有可能就是这个问题导致的