【详述】flink写入报错,
1.
Caused by: com.starrocks.connector.flink.manager.StarRocksStreamLoadFailedException: Failed to flush data to StarRocks, Error response:
{“Status”:“Fail”,“BeginTxnTimeMs”:0,“Message”:“Commit failed. txn: 35832936 table: ORDER tablet: 2270932 quorum: 1<2 errorReplicas: 2270935:{be:11072 x.x.x.x V:1324 LFV:1325},2270933:{be:11071 x.x.x.x V:1323 LFV:1324},”,“NumberUnselectedRows”:0,“CommitAndPublishTimeMs”:0,“Label”:“0c05b2dc-92c3-45ed-af39-981e63dbf43d27fbff60-b898-460d-8164-ca6a817895cb”,“LoadBytes”:729313,“StreamLoadPlanTimeMs”:14,“NumberTotalRows”:6816,“WriteDataTimeMs”:49460,“TxnId”:35832936,“LoadTimeMs”:49477,“ReadDataTimeMs”:0,“NumberLoadedRows”:6816,“NumberFilteredRows”:0}
{“columns”:“CRE_DT,UUID,UPDATE_TIME
”,“op_type”:“U”,“table”:“ORDER”}
[CIRCULAR REFERENCE:com.starrocks.connector.flink.manager.StarRocksStreamLoadFailedException: Failed to flush data to StarRocks, Error response:
{“Status”:“Fail”,“BeginTxnTimeMs”:0,“Message”:“call frontend service failed, address=TNetworkAddress(hostname=xx.x.xx.x, port=9020), reason=No more data to read.”,“NumberUnselectedRows”:0,“CommitAndPublishTimeMs”:0,“Label”:“a86f0cf9-c9fc-474e-82c2-760e82efe7192e8c04bb-5041-4c27-a418-f0bac6709e9a”,“LoadBytes”:0,“StreamLoadPlanTimeMs”:0,“NumberTotalRows”:0,“WriteDataTimeMs”:0,“TxnId”:-1,“LoadTimeMs”:0,“ReadDataTimeMs”:0,“NumberLoadedRows”:0,“NumberFilteredRows”:0}
{“columns”:“DT,UUID,cc
”,“op_type”:“U”,“table”:“v_HISTORY”}
【背景】io比较高
【业务影响】
【StarRocks版本】例如:2.4.3
【集群规模】:3fe(1 follower+2observer)+3be(fe与be混部)
【机器信息】:64C/256G/万兆
【联系方式】社区群14
【附件】