This is an automated email from the ASF dual-hosted git repository. kxiao pushed a commit to branch branch-2.0 in repository https://gitbox.apache.org/repos/asf/doris.git
commit 829ed30cac406997302ede9bbcf189f54561cf1e Author: wangqt <[email protected]> AuthorDate: Sat Oct 7 16:42:45 2023 +0800 [Fix](stream load) stearm load record use valid txn info when two txn with same label #24320 Co-authored-by: wangqingtao6 <[email protected]> --- fe/fe-core/src/main/java/org/apache/doris/load/StreamLoadRecordMgr.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/fe/fe-core/src/main/java/org/apache/doris/load/StreamLoadRecordMgr.java b/fe/fe-core/src/main/java/org/apache/doris/load/StreamLoadRecordMgr.java index 149d5c0a921..2848311f895 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/load/StreamLoadRecordMgr.java +++ b/fe/fe-core/src/main/java/org/apache/doris/load/StreamLoadRecordMgr.java @@ -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(); } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
