This is an automated email from the ASF dual-hosted git repository. tanxinyu pushed a commit to branch master_performance in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit a2899cd265fa3d274548b4f8b6168f7307f72898 Author: LebronAl <[email protected]> AuthorDate: Sat Nov 27 13:22:55 2021 +0800 add split log timer --- .../main/java/org/apache/iotdb/cluster/coordinator/Coordinator.java | 4 +++- .../src/main/java/org/apache/iotdb/cluster/server/monitor/Timer.java | 1 + .../src/main/java/org/apache/iotdb/db/qp/executor/PlanExecutor.java | 1 - 3 files changed, 4 insertions(+), 2 deletions(-) diff --git a/cluster/src/main/java/org/apache/iotdb/cluster/coordinator/Coordinator.java b/cluster/src/main/java/org/apache/iotdb/cluster/coordinator/Coordinator.java index 098b127..a59041a 100644 --- a/cluster/src/main/java/org/apache/iotdb/cluster/coordinator/Coordinator.java +++ b/cluster/src/main/java/org/apache/iotdb/cluster/coordinator/Coordinator.java @@ -36,6 +36,7 @@ import org.apache.iotdb.cluster.rpc.thrift.Node; import org.apache.iotdb.cluster.rpc.thrift.RaftNode; import org.apache.iotdb.cluster.server.member.MetaGroupMember; import org.apache.iotdb.cluster.server.monitor.Timer; +import org.apache.iotdb.cluster.server.monitor.Timer.Statistic; import org.apache.iotdb.cluster.utils.PartitionUtils; import org.apache.iotdb.cluster.utils.StatusUtils; import org.apache.iotdb.db.conf.IoTDBConstant; @@ -235,7 +236,7 @@ public class Coordinator { return concludeFinalStatus( plan, plan.getPaths().size(), true, false, false, null, Collections.emptyList()); } - + long startTime = Statistic.SPLIT_PLAN.getOperationStartTime(); // split the plan into sub-plans that each only involve one data group Map<PhysicalPlan, PartitionGroup> planGroupMap; try { @@ -244,6 +245,7 @@ public class Coordinator { return StatusUtils.getStatus( StatusUtils.CONSISTENCY_FAILURE, checkConsistencyException.getMessage()); } + Timer.Statistic.SPLIT_PLAN.calOperationCostTimeFromStart(startTime); // the storage group is not found locally if (planGroupMap == null || planGroupMap.isEmpty()) { diff --git a/cluster/src/main/java/org/apache/iotdb/cluster/server/monitor/Timer.java b/cluster/src/main/java/org/apache/iotdb/cluster/server/monitor/Timer.java index f4ac980..562e8cb 100644 --- a/cluster/src/main/java/org/apache/iotdb/cluster/server/monitor/Timer.java +++ b/cluster/src/main/java/org/apache/iotdb/cluster/server/monitor/Timer.java @@ -49,6 +49,7 @@ public class Timer { // meta group member META_GROUP_MEMBER_EXECUTE_NON_QUERY( META_GROUP_MEMBER, "execute non query", TIME_SCALE, true, COORDINATOR_EXECUTE_NON_QUERY), + SPLIT_PLAN(META_GROUP_MEMBER, "split plan", TIME_SCALE, true, COORDINATOR_EXECUTE_NON_QUERY), META_GROUP_MEMBER_EXECUTE_NON_QUERY_IN_LOCAL_GROUP( META_GROUP_MEMBER, "execute in local group", diff --git a/server/src/main/java/org/apache/iotdb/db/qp/executor/PlanExecutor.java b/server/src/main/java/org/apache/iotdb/db/qp/executor/PlanExecutor.java index aad4cdb..83e3e1d 100644 --- a/server/src/main/java/org/apache/iotdb/db/qp/executor/PlanExecutor.java +++ b/server/src/main/java/org/apache/iotdb/db/qp/executor/PlanExecutor.java @@ -1652,7 +1652,6 @@ public class PlanExecutor implements IPlanExecutor { return; } try { - logger.info("Execute insert tablet {}", insertTabletPlan.getRowCount()); insertTabletPlan.setMeasurementMNodes( new IMeasurementMNode[insertTabletPlan.getMeasurements().length]);
