This is an automated email from the ASF dual-hosted git repository. hui pushed a commit to branch lmh/addMetricDoc in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit dd57589f5d1db8d1766744cd2b740468b025a26f Author: Minghui Liu <[email protected]> AuthorDate: Thu Jan 12 14:48:22 2023 +0800 delete metric dispatcher:SCHEDULE --- .../java/org/apache/iotdb/db/mpp/metric/QueryExecutionMetricSet.java | 5 ----- .../java/org/apache/iotdb/db/mpp/plan/execution/QueryExecution.java | 5 ----- 2 files changed, 10 deletions(-) diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/metric/QueryExecutionMetricSet.java b/server/src/main/java/org/apache/iotdb/db/mpp/metric/QueryExecutionMetricSet.java index adaf851310..2c3f5d7bc9 100644 --- a/server/src/main/java/org/apache/iotdb/db/mpp/metric/QueryExecutionMetricSet.java +++ b/server/src/main/java/org/apache/iotdb/db/mpp/metric/QueryExecutionMetricSet.java @@ -34,15 +34,10 @@ public class QueryExecutionMetricSet implements IMetricSet { public static final Map<String, MetricInfo> metricInfoMap = new HashMap<>(); - public static final String SCHEDULE = "schedule"; public static final String WAIT_FOR_DISPATCH = "wait_for_dispatch"; public static final String DISPATCH_READ = "dispatch_read"; static { - metricInfoMap.put( - SCHEDULE, - new MetricInfo( - MetricType.TIMER, Metric.DISPATCHER.toString(), Tag.STAGE.toString(), SCHEDULE)); metricInfoMap.put( WAIT_FOR_DISPATCH, new MetricInfo( diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/QueryExecution.java b/server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/QueryExecution.java index 9cf25c433c..b0326403b0 100644 --- a/server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/QueryExecution.java +++ b/server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/QueryExecution.java @@ -81,7 +81,6 @@ import java.util.concurrent.atomic.AtomicBoolean; import static com.google.common.base.Preconditions.checkArgument; import static com.google.common.base.Throwables.throwIfUnchecked; import static org.apache.iotdb.db.mpp.common.DataNodeEndPoints.isSameNode; -import static org.apache.iotdb.db.mpp.metric.QueryExecutionMetricSet.SCHEDULE; import static org.apache.iotdb.db.mpp.metric.QueryExecutionMetricSet.WAIT_FOR_RESULT; import static org.apache.iotdb.db.mpp.metric.QueryPlanCostMetricSet.DISTRIBUTION_PLANNER; @@ -274,7 +273,6 @@ public class QueryExecution implements IQueryExecution { } // TODO: (xingtanzjr) initialize the query scheduler according to configuration - long startTime = System.nanoTime(); this.scheduler = new ClusterScheduler( context, @@ -286,9 +284,6 @@ public class QueryExecution implements IQueryExecution { scheduledExecutor, internalServiceClientManager); this.scheduler.start(); - if (rawStatement.isQuery()) { - QUERY_METRICS.recordExecutionCost(SCHEDULE, System.nanoTime() - startTime); - } } // Use LogicalPlanner to do the logical query plan and logical optimization
