flink升级doris connector版本之后,从savepoint启动报错

Viewed 7

flink 将flink-doris-connector-1.17-1.4.0.jar升级为flink-doris-connector-1.17-25.1.0.jar,先用flink stop --savepointPath hdfs://ns/flink-:savepoints/1.17.2/heartbeat/ ee52ce2bd8db3b5a7080b2970929a875 -yid application_1738834542534_0453命令停止flink on yarn的任务,然后用-s 参数从savepoints恢复的时候报错。
提示:
flink 版本为1.17.2
doris的版本为2.1.10

错误如下:
2025-12-18 19:13:11,305 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - desktopOnline38 -> Map -> doris-sink-heartbeart38: Writer -> doris-sink-heartbeart38: Committer (3/4) (c38f03e6bfa38b9b6d20c36ee98dfb01_00cb0645665f037cfb6558bd30889a6e_2_0) switched from INITIALIZING to FAILED on container_e13_1738834542534_0534_01_000002 @ cc-gzgz1dev-x86-ceph-3 (dataPort=44738).
org.apache.doris.flink.exception.DorisRuntimeException: commit transaction error,
at org.apache.doris.flink.sink.committer.DorisCommitter.commitTransaction(DorisCommitter.java:170) ~[flink-doris-connector-1.17-25.1.0.jar:25.1.0]
at org.apache.doris.flink.sink.committer.DorisCommitter.commit(DorisCommitter.java:98) ~[flink-doris-connector-1.17-25.1.0.jar:25.1.0]
at org.apache.flink.streaming.runtime.operators.sink.committables.CheckpointCommittableManagerImpl.commit(CheckpointCommittableManagerImpl.java:126) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.runtime.operators.sink.CommitterOperator.commitAndEmit(CommitterOperator.java:176) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.runtime.operators.sink.CommitterOperator.commitAndEmitCheckpoints(CommitterOperator.java:160) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.runtime.operators.sink.CommitterOperator.initializeState(CommitterOperator.java:121) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.api.operators.StreamOperatorStateHandler.initializeOperatorState(StreamOperatorStateHandler.java:122) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.api.operators.AbstractStreamOperator.initializeState(AbstractStreamOperator.java:274) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.initializeStateAndOpenOperators(RegularOperatorChain.java:106) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.runtime.tasks.StreamTask.restoreGates(StreamTask.java:734) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.call(StreamTaskActionExecutor.java:55) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.runtime.tasks.StreamTask.restoreInternal(StreamTask.java:709) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:675) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:952) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:921) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:745) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:562) ~[flink-dist-1.17.2.jar:1.17.2]
at java.lang.Thread.run(Thread.java:834) ~[?:?]
Caused by: org.apache.doris.flink.exception.DorisRuntimeException: commit transaction failed {
"status": "ANALYSIS_ERROR",
"msg": "TStatus: errCode = 2, detailMessage = transaction [92642587] not found"
}
at org.apache.doris.flink.sink.committer.DorisCommitter.commitTransaction(DorisCommitter.java:139) ~[flink-doris-connector-1.17-25.1.0.jar:25.1.0]
... 17 more

0 Answers