使用flink-doris-connector导入的时候,看taskmanager日志出现errCode = 2, detailMessage = transaction [19650] not found 的错误,是什么原因导致的呢
使用flink-doris-connector导入的时候,看taskmanager日志出现errCode = 2, detailMessage = transaction [19650] not found 的错误,是什么原因导致的呢
问题原因:
发生在Commit阶段,checkpoint里面记录的事务ID,在FE侧已经过期,此时再次commit就会出现上述错误。 此时无法从checkpoint启动
解决方式:
可通过修改fe.conf的streaming_label_keep_max_second配置来延长过期时间,默认12小时。