【详述】flink 导入sr报错
【背景】sink 端配置
2023-10-25 17:26:43,626 WARN com.starrocks.connector.flink.manager.StarRocksSinkManager [] - Failed to flush batch data to StarRocks, retry times = 0
com.starrocks.connector.flink.manager.StarRocksStreamLoadFailedException: Failed to flush data to StarRocks, Error response:
{“Status”:“Fail”,“BeginTxnTimeMs”:1,“Message”:“Cancelled because of runtime state is cancelled”,“NumberUnselectedRows”:0,“CommitAndPublishTimeMs”:0,“Label”:“a21c2200-a3b1-46f5-a1fe-17f569f757a2”,“LoadBytes”:188807662,“StreamLoadPlanTimeMs”:21,“NumberTotalRows”:0,“WriteDataTimeMs”:60834,“TxnId”:3779987,“LoadTimeMs”:60857,“ReadDataTimeMs”:310,“NumberLoadedRows”:0,“NumberFilteredRows”:0}
{}
at com.starrocks.connector.flink.manager.StarRocksStreamLoadVisitor.doStreamLoad(StarRocksStreamLoadVisitor.java:104) ~[blob_p-1e71c38b0b04f4dc6ddffca72e1c06743268f917-2873daad793c9399720ed485a179a975:?]
at com.starrocks.connector.flink.manager.StarRocksSinkManager.asyncFlush(StarRocksSinkManager.java:316) ~[blob_p-1e71c38b0b04f4dc6ddffca72e1c06743268f917-2873daad793c9399720ed485a179a975:?]
at com.starrocks.connector.flink.manager.StarRocksSinkManager.lambda$startAsyncFlushing$0(StarRocksSinkManager.java:160) ~[blob_p-1e71c38b0b04f4dc6ddffca72e1c06743268f917-2873daad793c9399720ed485a179a975:?]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_262]
2023-10-25 17:26:44,454 WARN com.starrocks.connector.flink.manager.StarRocksSinkManager [] - Failed to flush batch data to StarRocks, retry times = 0
com.starrocks.connector.flink.manager.StarRocksStreamLoadFailedException: Failed to flush data to StarRocks, Error response:
{“Status”:“Fail”,“BeginTxnTimeMs”:1,“Message”:“Cancelled because of runtime state is cancelled”,“NumberUnselectedRows”:0,“CommitAndPublishTimeMs”:0,“Label”:“762141e9-0e7f-484c-a103-8ec84305c463”,“LoadBytes”:188807498,“StreamLoadPlanTimeMs”:20,“NumberTotalRows”:0,“WriteDataTimeMs”:61002,“TxnId”:3779988,“LoadTimeMs”:61025,“ReadDataTimeMs”:308,“NumberLoadedRows”:0,“NumberFilteredRows”:0}
{}
at com.starrocks.connector.flink.manager.StarRocksStreamLoadVisitor.doStreamLoad(StarRocksStreamLoadVisitor.java:104) ~[blob_p-1e71c38b0b04f4dc6ddffca72e1c06743268f917-2873daad793c9399720ed485a179a975:?]
at com.starrocks.connector.flink.manager.StarRocksSinkManager.asyncFlush(StarRocksSinkManager.java:316) ~[blob_p-1e71c38b0b04f4dc6ddffca72e1c06743268f917-2873daad793c9399720ed485a179a975:?]
at com.starrocks.connector.flink.manager.StarRocksSinkManager.lambda$startAsyncFlushing$0(StarRocksSinkManager.java:160) ~[blob_p-1e71c38b0b04f4dc6ddffca72e1c06743268f917-2873daad793c9399720ed485a179a975:?]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_262
【业务影响】
【StarRocks版本】2.5.12
【集群规模】例如：3fe（1 follower+2observer）+3be（
【机器信息】CPU虚拟核/内存/网卡，例如：104C/512G/万兆
【表模型】例如：主键模型
【导入或者导出方式】例如：Flink
be.WARNING.lz4 (38.5 MB) fe.log.lz4 (10.9 MB)