This is an automated email from the ASF dual-hosted git repository.

dataroaring pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/doris.git


The following commit(s) were added to refs/heads/branch-3.0 by this push:
     new b6ecb19a9ee branch-3.0: [fix](log) fix group commit warn log (#42529)
b6ecb19a9ee is described below

commit b6ecb19a9ee0584058cf7b910e23a0bcdd797867
Author: github-actions[bot] 
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Thu Nov 7 14:06:06 2024 +0800

    branch-3.0: [fix](log) fix group commit warn log (#42529)
    
    if stream load in group commit mode connect to be directly, the fe does
    not select backend for it. the map used to record <table, be, dataSize>
    in fe is empty, so there are too many warn log:
    ```
    [GroupCommitManager.updateLoadDataInternal():399] can not find backend id: 
12229430
    2024-10-21 08:58:28,975 WARN (thrift-server-pool-7|132)
    ```
    
    Co-authored-by: meiyi <[email protected]>
---
 .../src/main/java/org/apache/doris/load/GroupCommitManager.java     | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/fe/fe-core/src/main/java/org/apache/doris/load/GroupCommitManager.java 
b/fe/fe-core/src/main/java/org/apache/doris/load/GroupCommitManager.java
index 815aa983ad8..3177f96cb86 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/load/GroupCommitManager.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/load/GroupCommitManager.java
@@ -393,10 +393,10 @@ public class GroupCommitManager {
     private void updateLoadDataInternal(long tableId, long receiveData) {
         if (tableToPressureMap.containsKey(tableId)) {
             tableToPressureMap.get(tableId).add(receiveData);
-            LOG.info("Update load data for table{}, receiveData {}, 
tablePressureMap {}", tableId, receiveData,
+            LOG.info("Update load data for table {}, receiveData {}, 
tablePressureMap {}", tableId, receiveData,
                     tableToPressureMap.toString());
-        } else {
-            LOG.warn("can not find backend id: {}", tableId);
+        } else if (LOG.isDebugEnabled()) {
+            LOG.debug("can not find table id {}", tableId);
         }
     }
 }


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to