(iotdb) branch beyyes/multi_devices_fe updated: remove logs

[caogaofei]

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

caogaofei pushed a commit to branch beyyes/multi_devices_fe
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/beyyes/multi_devices_fe by 
this push:
     new 48c15c4b92a remove logs
48c15c4b92a is described below

commit 48c15c4b92a3838f62ec77e2943e5542038d2fa0
Author: Beyyes <cgf1...@foxmail.com>
AuthorDate: Tue Nov 21 10:20:52 2023 +0800

    remove logs
---
 .../apache/iotdb/db/queryengine/plan/Coordinator.java   |  3 ---
 .../db/queryengine/plan/analyze/TemplatedAnalyze.java   | 17 -----------------
 .../db/queryengine/plan/execution/QueryExecution.java   |  6 ------
 3 files changed, 26 deletions(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/Coordinator.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/Coordinator.java
index a3c58315f07..1487a0f9932 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/Coordinator.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/Coordinator.java
@@ -158,9 +158,6 @@ public class Coordinator {
         queryContext.setTimeOut(Long.MAX_VALUE);
       }
       execution.start();
-      LOGGER.warn(
-          "========= Consume time in Coordinator.execute: {}ms",
-          System.currentTimeMillis() - startTime);
       return execution.getStatus();
     }
   }
diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/TemplatedAnalyze.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/TemplatedAnalyze.java
index e9b0a213708..0053b6a48fe 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/TemplatedAnalyze.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/TemplatedAnalyze.java
@@ -140,17 +140,11 @@ public class TemplatedAnalyze {
       return false;
     }
 
-    long startTime = System.currentTimeMillis();
     analyzeSelect(queryStatement, analysis, outputExpressions, template);
-    LOGGER.warn("--- [analyzeSelect] : {}ms", System.currentTimeMillis() - 
startTime);
 
     List<PartialPath> deviceList = analyzeFrom(queryStatement, schemaTree);
-    LOGGER.warn("--- [analyzeFrom] : {}ms", System.currentTimeMillis() - 
startTime);
-    startTime = System.currentTimeMillis();
 
     analyzeDeviceToWhere(analysis, queryStatement, schemaTree, deviceList);
-    LOGGER.warn("--- [analyzeDeviceToWhere] : {}ms", 
System.currentTimeMillis() - startTime);
-    startTime = System.currentTimeMillis();
 
     if (deviceList.isEmpty()) {
       analysis.setFinishQueryAfterAnalyze(true);
@@ -162,27 +156,16 @@ public class TemplatedAnalyze {
     analyzeDeviceToSourceTransform(analysis);
     analyzeDeviceToSource(analysis);
 
-    LOGGER.warn(
-        "--- [analyzeDeviceToSource + analyzeDeviceToSourceTransform] : {}ms",
-        System.currentTimeMillis() - startTime);
-    startTime = System.currentTimeMillis();
-
     analyzeDeviceViewOutput(analysis, queryStatement);
     analyzeDeviceViewInput(analysis);
 
-    LOGGER.warn("--- [analyzeDeviceView] : {}ms", System.currentTimeMillis() - 
startTime);
-    startTime = System.currentTimeMillis();
-
     analyzeFill(analysis, queryStatement);
 
     // generate result set header according to output expressions
     analyzeOutput(analysis, queryStatement, outputExpressions);
-    LOGGER.warn("--- [analyzeOutput] : {}ms", System.currentTimeMillis() - 
startTime);
-    startTime = System.currentTimeMillis();
 
     // fetch partition information
     analyzeDataPartition(analysis, schemaTree, partitionFetcher);
-    LOGGER.warn("--- [analyzeDataPartition] : {}ms", 
System.currentTimeMillis() - startTime);
     return true;
   }
 
diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/QueryExecution.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/QueryExecution.java
index 0e4ca231b3c..cde215150fe 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/QueryExecution.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/QueryExecution.java
@@ -217,16 +217,11 @@ public class QueryExecution implements IQueryExecution {
       return;
     }
 
-    long lastRecordTime = System.currentTimeMillis();
     // check timeout for query first
     checkTimeOutForQuery();
     doLogicalPlan();
-    logger.warn("--- [doLogicalPlan] : {}ms", System.currentTimeMillis() - 
lastRecordTime);
-    lastRecordTime = System.currentTimeMillis();
 
     doDistributedPlan();
-    logger.warn("--- [doDistributedPlan] : {}ms", System.currentTimeMillis() - 
lastRecordTime);
-    lastRecordTime = System.currentTimeMillis();
 
     // update timeout after finishing plan stage
     context.setTimeOut(
@@ -238,7 +233,6 @@ public class QueryExecution implements IQueryExecution {
     }
     PERFORMANCE_OVERVIEW_METRICS.recordPlanCost(System.nanoTime() - startTime);
     schedule();
-    logger.warn("--- [schedule] : {}ms", System.currentTimeMillis() - 
lastRecordTime);
 
     // set partial insert error message
     // When some columns in one insert failed, other column will continue 
executing insertion.