From 976335e236ad91b1036c6578e79b29ab406671c9 Mon Sep 17 00:00:00 2001
From: wangqt <mongo3600@gmail.com>
Date: Sat, 7 Oct 2023 16:42:45 +0800
Subject: [PATCH] [Fix](stream load) stearm load record use valid txn info when
 two txn with same label #24320

Co-authored-by: wangqingtao6 <wangqingtao6@jd.com>
---
 .../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 149d5c0a92..2848311f89 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();
     }