From a404ff5ab990ed7aac7fdb607d09f4ea4ab54227 Mon Sep 17 00:00:00 2001
From: meiyi <myimeiyi@gmail.com>
Date: Tue, 7 Nov 2023 18:17:45 +0800
Subject: [PATCH] [fix](regression) fix group commit regression test (#26519)

---
 be/src/runtime/stream_load/new_load_stream_mgr.h | 9 ++++++---
 1 file changed, 6 insertions(+), 3 deletions(-)

diff --git a/be/src/runtime/stream_load/new_load_stream_mgr.h b/be/src/runtime/stream_load/new_load_stream_mgr.h
index 9c33854436..45be8bb306 100644
--- a/be/src/runtime/stream_load/new_load_stream_mgr.h
+++ b/be/src/runtime/stream_load/new_load_stream_mgr.h
@@ -45,12 +45,14 @@ public:
         {
             std::lock_guard<std::mutex> l(_lock);
             if (auto iter = _stream_map.find(id); iter != _stream_map.end()) {
-                return Status::InternalError("id already exist");
+                std::stringstream ss;
+                ss << "id: " << id << " already exist";
+                return Status::InternalError(ss.str());
             }
             _stream_map.emplace(id, stream);
         }
 
-        VLOG_NOTICE << "put stream load pipe: " << id;
+        LOG(INFO) << "put stream load pipe: " << id;
         return Status::OK();
     }
 
@@ -61,6 +63,7 @@ public:
                 return iter->second;
             }
         }
+        LOG(INFO) << "stream load pipe does not exist: " << id;
         return nullptr;
     }
 
@@ -68,7 +71,7 @@ public:
         std::lock_guard<std::mutex> l(_lock);
         if (auto iter = _stream_map.find(id); iter != _stream_map.end()) {
             _stream_map.erase(iter);
-            VLOG_NOTICE << "remove stream load pipe: " << id;
+            LOG(INFO) << "remove stream load pipe: " << id;
         }
     }