为了更快的定位您的问题，请提供以下信息，谢谢
【详述】
sink.version配置的V1就可以实现同步 配置V2就不行
Transaction start, label : flink-e522bcd8-d380-488b-9466-29679f37b579
09:52:28.288[INFO ]Transaction start, db: db_test, table: T_D_AI_ACT_VAL, label: flink-e522bcd8-d380-488b-9466-29679f37b579, request : POST http://10.10.91.107:8040/api/transaction/begin HTTP/1.1
09:52:28.427[INFO ]Transaction started, db: db_test, table: T_D_AI_ACT_VAL, label: flink-e522bcd8-d380-488b-9466-29679f37b579, body : {
“Status”: “OK”,
“Message”: “”,
“Label”: “flink-e522bcd8-d380-488b-9466-29679f37b579”,
“TxnId”: 3270,
“BeginTxnTimeMs”: 103
}
09:52:28.435[INFO ]Stream loading, label : flink-e522bcd8-d380-488b-9466-29679f37b579, region : db_test-T_D_AI_ACT_VAL, request : PUT http://10.10.91.107:8040/api/transaction/load HTTP/1.1
09:52:28.618[INFO ]Write entity for table db_test-T_D_AI_ACT_VAL, size:341, time:7us
09:52:28.669[INFO ]Stream load completed, label : flink-e522bcd8-d380-488b-9466-29679f37b579, database : db_test, table : T_D_AI_ACT_VAL, body : {
“Status”: “OK”,
“Message”: “”,
“Label”: “flink-e522bcd8-d380-488b-9466-29679f37b579”,
“TxnId”: 3270,
“LoadBytes”: 341,
“StreamLoadPlanTimeMs”: 110,
“ReceivedDataTimeMs”: 0
}
09:52:28.671[INFO ]Receive load response, cacheByteBeforeFlush: 340, currentCacheBytes: 0, totalFlushRows : 1
09:52:28.671[INFO ]Stream load completed, db: db_test, table: T_D_AI_ACT_VAL, label: flink-e522bcd8-d380-488b-9466-29679f37b579, cacheBytes: 0, cacheRows: 0
09:52:28.678[INFO ]Transaction prepare, label : flink-e522bcd8-d380-488b-9466-29679f37b579, request : POST http://10.10.91.107:8040/api/transaction/prepare HTTP/1.1
09:52:28.822[INFO ]Transaction prepared, label : flink-e522bcd8-d380-488b-9466-29679f37b579, body : {
“Status”: “OK”,
“Message”: “”,
“Label”: “flink-e522bcd8-d380-488b-9466-29679f37b579”,
“TxnId”: 3270,
“NumberTotalRows”: 1,
“NumberLoadedRows”: 1,
“NumberFilteredRows”: 0,
“NumberUnselectedRows”: 0,
“LoadBytes”: 341,
“LoadTimeMs”: 501,
“StreamLoadPlanTimeMs”: 110,
“ReceivedDataTimeMs”: 0,
“WriteDataTimeMs”: 110,
“CommitAndPublishTimeMs”: 105
}
09:52:28.822[INFO ]Receive load response, cacheByteBeforeFlush: 0, currentCacheBytes: 0, totalFlushRows : 1
09:52:28.838[INFO ]Transaction commit, label: flink-e522bcd8-d380-488b-9466-29679f37b579, request : POST http://10.10.91.107:8040/api/transaction/commit HTTP/1.1
09:52:28.914[INFO ]Transaction committed, lable: flink-e522bcd8-d380-488b-9466-29679f37b579, body : {
“Status”: “TXN_NOT_EXISTS”,
“Message”: “transaction with label flink-e522bcd8-d380-488b-9466-29679f37b579 not exists”
}
09:52:29.037[INFO ]Response for get_load_state, label: flink-e522bcd8-d380-488b-9466-29679f37b579, response status code: 404, response body :
Not Found
09:52:29.037[ERROR]TransactionTableRegion commit failed, db: db_test, table: T_D_AI_ACT_VAL, label: flink-e522bcd8-d380-488b-9466-29679f37b579
java.lang.RuntimeException: com.starrocks.data.load.stream.exception.StreamLoadFailException: Could not get load state because of incorrect response status code 404, label: flink-e522bcd8-d380-488b-9466-29679f37b579, response body:
Not Found
at com.starrocks.data.load.stream.TransactionStreamLoader.commit(TransactionStreamLoader.java:310) ~[flink-connector-starrocks-1.2.10_flink-1.17.jar:?]
at com.starrocks.data.load.stream.v2.TransactionTableRegion.doCommit(TransactionTableRegion.java:308) ~[flink-connector-starrocks-1.2.10_flink-1.17.jar:?]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:1.8.0_431]
at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_431]
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180) [?:1.8.0_431]
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293) [?:1.8.0_431]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_431]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_431]
at java.lang.Thread.run(Thread.java:750) [?:1.8.0_431]
Caused by: com.starrocks.data.load.stream.exception.StreamLoadFailException: Could not get load state because of incorrect response status code 404, label: flink-e522bcd8-d380-488b-9466-29679f37b579, response body:
404 Not FoundNot Found
at com.starrocks.data.load.stream.DefaultStreamLoader.getLabelState(DefaultStreamLoader.java:471) ~[flink-connector-starrocks-1.2.10_flink-1.17.jar:?]
at com.starrocks.data.load.stream.TransactionStreamLoader.commit(TransactionStreamLoader.java:290) ~[flink-connector-starrocks-1.2.10_flink-1.17.jar:?]
... 8 more
【背景】Flink实现源库达梦库到目标MySQL库数据同步
【StarRocks版本】3.3.0
【Flink-connector-starrocks版本】1.17
【附件】
