This is an automated email from the ASF dual-hosted git repository.
marklau99 pushed a commit to branch cpu-monitor
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/cpu-monitor by this push:
new 7b4286ce40 add all thread name in datanode
7b4286ce40 is described below
commit 7b4286ce4092e910fbe7a6dd1e2c9ce04806a442
Author: Liu Xuxin <[email protected]>
AuthorDate: Mon Apr 10 17:06:57 2023 +0800
add all thread name in datanode
---
.../metrics/metricsets/cpu/CpuMetricsConstant.java | 61 ++++++++++++++++++++--
1 file changed, 58 insertions(+), 3 deletions(-)
diff --git
a/metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/cpu/CpuMetricsConstant.java
b/metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/cpu/CpuMetricsConstant.java
index b19203eff0..2f0eb011a6 100644
---
a/metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/cpu/CpuMetricsConstant.java
+++
b/metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/cpu/CpuMetricsConstant.java
@@ -23,8 +23,11 @@ public class CpuMetricsConstant {
public static final String DATA_NODE = "datanode";
public static final String CONFIG_NODE = "confignode";
public static final String[] DATA_NODE_MODULES =
- new String[] {"query", "write", "flush", "compaction", "consensus",
"metadata", "sync"};
- public static final String[] CONFIG_NODE_MODULES = new String[]
{"consensus", "rpc"};
+ new String[] {
+ "query", "write", "flush", "compaction", "consensus", "metadata",
"client", "compile", "gc"
+ };
+ public static final String[] CONFIG_NODE_MODULES =
+ new String[] {"consensus", "rpc", "compile", "gc"};
// thread name
// -------------------------- QueryThreads --------------------------
@@ -40,9 +43,61 @@ public class CpuMetricsConstant {
"MPPDataExchangeRPC-Processor";
public static final String MPP_DATA_EXCHANGE_EXECUTOR_THREAD_NAME =
"mpp-data-exchange-task-executors";
+ public static final String MPP_COORDINATOR_THREAD_NAME = "MPPCoordinator";
+ public static final String MPP_COORDINATOR_SCHEDULE_THREAD_NAME =
"MPPCoordinatorScheduled";
public static final String FRAGMENT_INSTANCE_MANAGEMENT_THREAD_NAME =
"instance-management";
public static final String FRAGMENT_INSTANCE_NOTIFICATION_THREAD_NAME =
"instance-notification";
+ public static final String TIMED_QUERY_COUNT_THREAD_NAME =
"timedQuerySqlCount";
- // -------------------------- ConsensusThreads --------------------------
+ // -------------------------- RatisConsensusThreads
--------------------------
+ public static final String RAFT_SERVER_PROXY_EXECUTOR_THREAD_NAME_PATTERN =
"\\d+-impl";
+ public static final String JVM_PAUSE_MONITOR_THREAD_NAME = "JvmPauseMonitor";
+ public static final String RAFT_SERVER_EXECUTOR_THREAD_NAME_PATTERN =
"\\d+-server";
+ public static final String RAFT_SERVER_CLIENT_EXECUTOR_THREAD_NAME_PATTERN =
"\\d+-client";
+ public static final String SEGMENT_RAFT_WORKER_THREAD_NAME_PATTERN =
+ "\\d+-SegmentedRaftLogWorker";
+ public static final String STATE_MACHINE_UPDATER_THREAD_NAME_PATTERN =
"\\d+-StateMachineUpdater";
+ public static final String FOLLOWER_STATE_THREAD_NAME_PATTERN =
"\\d+-FollowerState";
+ public static final String LEADER_STATE_IMPL_PROCESSOR_THREAD_NAME =
"LeaderStateImpl";
+ public static final String LEADER_ELECTION_THREAD_NAME_PATTERN =
"\\d+-LeaderElection";
+ public static final String LOG_APPENDER_THREAD_NAME_PATTERN =
"\\d+-GrpcLogAppender";
+ public static final String LEADER_STATE_IMPL_PROCESSOR_THREAD_NAME_PATTERN =
+ "\\d+-EventProcessor";
+ public static final String RATIS_BG_DISK_GUARDIAN_THREAD_NAME_PATTERN =
"ratis-bg-disk-guardian";
+ public static final String GRPC_DEFAULT_BOSS_ELG = "grpc-default-boss-ELG";
+ // TODO: Add IoTConsensus Threads
+
+ // -------------------------- CompactionThreads --------------------------
+ public static final String COMPACTION_EXECUTOR_THREAD_NAME =
"IoTDB-Compaction";
+ public static final String COMPACTION_SUB_TASK_THREAD_NAME =
"IoTDB-Sub-Compaction";
+ public static final String COMPACTION_SCHEDULER_THREAD_NAME =
"IoTDB-Compaction_Scheduler";
+
+ // -------------------------- FlushThreads --------------------------
+ public static final String FLUSH_THREAD_NAME_PATTERN = "Flush";
+ public static final String FLUSH_SUB_TASK_THREAD_NAME_PATTERN =
"Flush-SubTask";
+ public static final String TIMED_FLUSH_THREAD_NAME_PATTERN = "Timed-Flush";
+ public static final String TTL_CHECKED_THREAD_NAME_PATTERN = "TTL-Check";
+
+ // -------------------------- WalThreads --------------------------
+ public static final String WAL_SERIALIZED_THREAD_NAME = "WAL-Serialize";
+ public static final String WAL_SYNC_THREAD_NAME = "WAL-Sync";
+ public static final String WAL_DELETE_THREAD_NAME = "WAL-Delete";
+ public static final String WAL_RECOVER_THREAD_NAME = "WAL-Recover";
+
+ // -------------------------- MetadataThreads --------------------------
+ public static final String SCHEMA_ENGINE_RECOVER_THREAD_PATTERN =
"SchemaRegion-Recover-Task";
+ public static final String MTREE_FLUSH_TASK_THREAD_PATTERN =
"MTree-Flush-Task";
+ public static final String MTREE_RELEASE_TASK_THREAD_PATTERN =
"MTree-Release-Task";
+
+ // -------------------------- ClientThreads --------------------------
+ public static final String CLIENT_RCP_THREAD_NAME = "ClientRPC-Processor";
+
+ // -------------------------- LogBackThreads --------------------------
+ public static final String LOGBACK_THREAD_NAME = "logback";
+
+ // -------------------------- CompileThreads --------------------------
+ public static final String COMPILE_THREAD_NAME = "CompilerThread";
+ // -------------------------- GcThreads --------------------------
+ public static final String GC_THREAD_NAME = "GC task thread";
}
