flink 版本:1.14.5
flink cdc 版本:2.2.1
doris 版本 :1.2.6
doris connector 版本:1.1.1
使用以上环境读取sqlserver 数据时,能通过cdc 获取到数据,执行flink job也能看到以下 flink 日志
2025-03-03 10:50:25,049 INFO DorisStreamLoad:214 - stream load stopped.
2025-03-03 10:50:25,074 INFO DorisStreamLoad:206 - load Result {
"TxnId": 5731720,
"Label": "20250303104922_ce93e3da41df464385b090de970932e1_0_1",
"TwoPhaseCommit": "true",
"Status": "Success",
"Message": "OK",
"NumberTotalRows": 0,
"NumberLoadedRows": 0,
"NumberFilteredRows": 0,
"NumberUnselectedRows": 0,
"LoadBytes": 26189,
"LoadTimeMs": 48723,
"BeginTxnTimeMs": 0,
"StreamLoadPutTimeMs": 1,
"ReadDataTimeMs": 0,
"WriteDataTimeMs": 3,
"CommitAndPublishTimeMs": 0
}
但是doris的表里面没有数据,查看fe.log,在fe.log里面发现对应的Label 同步作业出现错误信息: abort transaction: TransactionState. transaction id: 5682010, label: 20250303104922_ce93e3da41df464385b090de970932e1_0_1, db id: 1346937, table id list: 1346972, callback id: -1, coordinator: BE: 10.x.xx.xx, transaction status: ABORTED, error replicas num: 0, replica ids: , prepare time: 1740558975136, commit time: -1, finish time: 1740558975205, reason: User Abort successfully
有大佬帮忙看一下吗