diff --git a/kyuubi-metrics/src/main/scala/org/apache/kyuubi/metrics/MetricsConstants.scala b/kyuubi-metrics/src/main/scala/org/apache/kyuubi/metrics/MetricsConstants.scala index a2c9afd0f..c0ada08ba 100644 --- a/kyuubi-metrics/src/main/scala/org/apache/kyuubi/metrics/MetricsConstants.scala +++ b/kyuubi-metrics/src/main/scala/org/apache/kyuubi/metrics/MetricsConstants.scala @@ -21,6 +21,12 @@ object MetricsConstants { final private val KYUUBI = "kyuubi." + final val GC_METRIC: String = KYUUBI + "gc" + final val MEMORY_USAGE: String = KYUUBI + "memory_usage" + final val BUFFER_POOL: String = KYUUBI + "buffer_pool" + final val THREAD_STATE: String = KYUUBI + "thread_state" + final val CLASS_LOADING: String = KYUUBI + "class_loading" + final val EXEC_POOL_ALIVE: String = KYUUBI + "exec.pool.threads.alive" final val EXEC_POOL_ACTIVE: String = KYUUBI + "exec.pool.threads.active" diff --git a/kyuubi-metrics/src/main/scala/org/apache/kyuubi/metrics/MetricsSystem.scala b/kyuubi-metrics/src/main/scala/org/apache/kyuubi/metrics/MetricsSystem.scala index 389dba08c..3622ff8d7 100644 --- a/kyuubi-metrics/src/main/scala/org/apache/kyuubi/metrics/MetricsSystem.scala +++ b/kyuubi-metrics/src/main/scala/org/apache/kyuubi/metrics/MetricsSystem.scala @@ -67,10 +67,13 @@ class MetricsSystem extends CompositeService("MetricsSystem") { } override def initialize(conf: KyuubiConf): Unit = synchronized { - registry.registerAll(new GarbageCollectorMetricSet) - registry.registerAll(new MemoryUsageGaugeSet) - registry.registerAll(new BufferPoolMetricSet(ManagementFactory.getPlatformMBeanServer)) - registry.registerAll(new ThreadStatesGaugeSet) + registry.registerAll(MetricsConstants.GC_METRIC, new GarbageCollectorMetricSet) + registry.registerAll(MetricsConstants.MEMORY_USAGE, new MemoryUsageGaugeSet) + registry.registerAll( + MetricsConstants.BUFFER_POOL, + new BufferPoolMetricSet(ManagementFactory.getPlatformMBeanServer)) + registry.registerAll(MetricsConstants.THREAD_STATE, new ThreadStatesGaugeSet) + registry.registerAll(MetricsConstants.CLASS_LOADING, new ClassLoadingGaugeSet) conf.get(METRICS_REPORTERS).map(ReporterType.withName).foreach { case JSON => addService(new JsonReporterService(registry))