Log on fe

apache · Dec 20, 2023 · a8553e1 · a8553e1
1 parent f167120
commit a8553e1
Showing 1 changed file with 3 additions and 7 deletions.
diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/QeProcessorImpl.java b/fe/fe-core/src/main/java/org/apache/doris/qe/QeProcessorImpl.java
@@ -128,9 +128,7 @@ public Map<String, Integer> getInstancesNumPerUser() {
     public void unregisterQuery(TUniqueId queryId) {
         QueryInfo queryInfo = coordinatorMap.remove(queryId);
         if (queryInfo != null) {
-            if (LOG.isDebugEnabled()) {
-                LOG.debug("deregister query id {}", DebugUtil.printId(queryId));
-            }
+            LOG.info("deregister query id {}", DebugUtil.printId(queryId));
             if (queryInfo.getConnectContext() != null
                     && !Strings.isNullOrEmpty(queryInfo.getConnectContext().getQualifiedUser())
             ) {
@@ -139,7 +137,7 @@ public void unregisterQuery(TUniqueId queryId) {
                     String user = queryInfo.getConnectContext().getQualifiedUser();
                     AtomicInteger instancesNum = userToInstancesCount.get(user);
                     if (instancesNum == null) {
-                        LOG.warn("WTF?? query {} in queryToInstancesNum but not in userToInstancesCount",
+                        LOG.warn("Query {} in queryToInstancesNum but not in userToInstancesCount",
                                 DebugUtil.printId(queryId)
                         );
                     } else {
@@ -148,9 +146,7 @@ public void unregisterQuery(TUniqueId queryId) {
                 }
             }
         } else {
-            if (LOG.isDebugEnabled()) {
-                LOG.debug("not found query {} when unregisterQuery", DebugUtil.printId(queryId));
-            }
+            LOG.info("not found query {} when unregisterQuery", DebugUtil.printId(queryId));
         }
 
         // commit hive tranaction if needed