为了更快的定位您的问题,请提供以下信息,谢谢
【详述】FlinkSQL程序实时处理Kafka数据并将结果写入StarRocks集群,任务启动后,运行一段时间后(12小时以内)会跑出空指针异常
【背景】INSERT 操作
【业务影响】
【StarRocks版本】2.5
【flink-connector-starrocks版本】1.2.3_flink-1.15
【集群规模】3fe(1 follower+2observer)+6be(fe与be无混部)
【机器信息】CPU虚拟核/内存/网卡,32C/128G
【表模型】主键模型
【导入或者导出方式】使用Flink写入
【联系方式】StarRocks社区群5-月升;个人邮箱:18406505214@163.com
【附件】
麻烦提供2.5具体版本,还有麻烦把日志以文本方式发一下,谢谢!
fe03_warn.log (1.1 MB) fe03.log (27.9 MB) fe02_warn.log (1.0 MB) fe01_warn.log (5.1 MB) flink日志.log (178.8 KB)
flink日志文件为出现问题时间点的部分flink程序日志
03节点是fe的leader
starrocks版本:2.5.3
以上为出现报错的时间部分日志,麻烦您了,谢谢
修复过了,flink-connector升级 1.2.7
方便可以同步一下是什么原因嘛,感谢呢
老师,请教一下这个问题是什么原因造成的呢,1.2.3的flink连接包存在什么bug呀