database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[Fix](stream load) stearm load record use valid txn info when two txn with same label #24320

Browse Source 
Co-authored-by: wangqingtao6 <wangqingtao6@jd.com>
This commit is contained in:
wangqt
2023-10-07 16:42:45 +08:00
committed by GitHub
parent 59261174d5
commit 976335e236
1 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
fe/fe-core/src/main/java/org/apache/doris/load/StreamLoadRecordMgr.java
View File

@ -142,6 +142,8 @@ public class StreamLoadRecordMgr extends MasterDaemon {
Map<String, StreamLoadRecord> labelToStreamLoadRecord = dbIdToLabelToStreamLoadRecord.get(dbId);
if (!labelToStreamLoadRecord.containsKey(label)) {
labelToStreamLoadRecord.put(label, streamLoadRecord);
} else if (labelToStreamLoadRecord.get(label).getFinishTime().compareTo(streamLoadRecord.getFinishTime()) < 0) {
labelToStreamLoadRecord.put(label, streamLoadRecord);
}
writeUnlock();
}