flinkcdc作业在将kafka数据发送到starrocks时候，遇到异常，flink作业多次重启，之后又恢复正常运行，但是有出现数据丢失问题，目前看flink作业这边报异常作业从 RUNNING 状态变为 RESTARTING 状态，异常消息：com.starrocks.data.load.stream.exception.StreamLoadFailException: Transaction prepare failed because of unexpected state, label: 74765e6e-5f75-430e-8c5a-aa4e6efcdb2f, state: ABORTED at com.starrocks.data.load.stream.TransactionStreamLoader.prepare(TransactionStreamLoader.java:190) at com.starrocks，已经拉取了日志，我看的不明白，希望老师帮忙看下谢谢
请按照文档规范操作