From 23da3e96c4dfaa2e730092bfed597443cfb7fbda Mon Sep 17 00:00:00 2001
From: laihui <1353307710@qq.com>
Date: Fri, 30 Aug 2024 14:33:20 +0800
Subject: [PATCH] remove some invalid log

---
 .../doris/load/StreamLoadRecordMgr.java       | 28 +++++++++----------
 1 file changed, 13 insertions(+), 15 deletions(-)

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 020b38158d1855..7f1d33bd649736 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
@@ -150,19 +150,16 @@ public void addStreamLoadRecord(long dbId, String label, StreamLoadRecord stream
     }
 
     public List<StreamLoadItem> getStreamLoadRecords() {
-        LOG.info("test log: {}", streamLoadRecordHeap);
         return new ArrayList<>(streamLoadRecordHeap);
     }
 
     public List<List<Comparable>> getStreamLoadRecordByDb(
             long dbId, String label, boolean accurateMatch, StreamLoadState state) {
         LinkedList<List<Comparable>> streamLoadRecords = new LinkedList<List<Comparable>>();
-        LOG.info("test log: {}", dbId);
 
         readLock();
         try {
             if (!dbIdToLabelToStreamLoadRecord.containsKey(dbId)) {
-                LOG.info("test log: {}", dbId);
                 return streamLoadRecords;
             }
 
@@ -205,7 +202,6 @@ public List<List<Comparable>> getStreamLoadRecordByDb(
                 }
 
             }
-            LOG.info("test log: {}", streamLoadRecords);
             return streamLoadRecords;
         } finally {
             readUnlock();
@@ -273,17 +269,19 @@ protected void runAfterCatalogReady() {
                             TimeUtils.getDatetimeMsFormatWithTimeZone());
                     String finishTime = TimeUtils.longToTimeString(streamLoadItem.getFinishTime(),
                             TimeUtils.getDatetimeMsFormatWithTimeZone());
-                    LOG.info("receive stream load record info from backend: {}."
-                                    + " label: {}, db: {}, tbl: {}, user: {}, user_ip: {},"
-                                    + " status: {}, message: {}, error_url: {},"
-                                    + " total_rows: {}, loaded_rows: {}, filtered_rows: {}, unselected_rows: {},"
-                                    + " load_bytes: {}, start_time: {}, finish_time: {}.",
-                            backend.getHost(), streamLoadItem.getLabel(), streamLoadItem.getDb(),
-                            streamLoadItem.getTbl(), streamLoadItem.getUser(), streamLoadItem.getUserIp(),
-                            streamLoadItem.getStatus(), streamLoadItem.getMessage(), streamLoadItem.getUrl(),
-                            streamLoadItem.getTotalRows(), streamLoadItem.getLoadedRows(),
-                            streamLoadItem.getFilteredRows(), streamLoadItem.getUnselectedRows(),
-                            streamLoadItem.getLoadBytes(), startTime, finishTime);
+                    if (LOG.isDebugEnabled()) {
+                        LOG.debug("receive stream load record info from backend: {}."
+                                        + " label: {}, db: {}, tbl: {}, user: {}, user_ip: {},"
+                                        + " status: {}, message: {}, error_url: {},"
+                                        + " total_rows: {}, loaded_rows: {}, filtered_rows: {}, unselected_rows: {},"
+                                        + " load_bytes: {}, start_time: {}, finish_time: {}.",
+                                backend.getHost(), streamLoadItem.getLabel(), streamLoadItem.getDb(),
+                                streamLoadItem.getTbl(), streamLoadItem.getUser(), streamLoadItem.getUserIp(),
+                                streamLoadItem.getStatus(), streamLoadItem.getMessage(), streamLoadItem.getUrl(),
+                                streamLoadItem.getTotalRows(), streamLoadItem.getLoadedRows(),
+                                streamLoadItem.getFilteredRows(), streamLoadItem.getUnselectedRows(),
+                                streamLoadItem.getLoadBytes(), startTime, finishTime);
+                    }
 
                     AuditEvent auditEvent =
                             new StreamLoadAuditEvent.AuditEventBuilder().setEventType(EventType.STREAM_LOAD_FINISH)