diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/ModularLoadManagerImpl.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/ModularLoadManagerImpl.java index c20730e80d386..e9f7057c61a50 100644 --- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/ModularLoadManagerImpl.java +++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/ModularLoadManagerImpl.java @@ -689,8 +689,8 @@ private void updateBundleUnloadingMetrics(Multimap bundlesToUnlo dimensions.put("metric", "bundleUnloading"); Metrics m = Metrics.create(dimensions); - m.put("brk_lb_unload_broker_count", unloadBrokerCount); - m.put("brk_lb_unload_bundle_count", unloadBundleCount); + m.put("brk_lb_unload_broker_total", unloadBrokerCount); + m.put("brk_lb_unload_bundle_total", unloadBundleCount); metrics.add(m); this.bundleUnloadMetrics.set(metrics); } @@ -781,7 +781,7 @@ private void updateBundleSplitMetrics(Set bundlesToBeSplit) { dimensions.put("metric", "bundlesSplit"); Metrics m = Metrics.create(dimensions); - m.put("brk_lb_bundles_split_count", bundleSplitCount); + m.put("brk_lb_bundles_split_total", bundleSplitCount); metrics.add(m); this.bundleSplitMetrics.set(metrics); } diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/broker/stats/PrometheusMetricsTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/broker/stats/PrometheusMetricsTest.java index 8eccf1785e4bf..d9d1b25665cc8 100644 --- a/pulsar-broker/src/test/java/org/apache/pulsar/broker/stats/PrometheusMetricsTest.java +++ b/pulsar-broker/src/test/java/org/apache/pulsar/broker/stats/PrometheusMetricsTest.java @@ -490,7 +490,7 @@ public void testBundlesMetrics() throws Exception { assertTrue(metrics.containsKey("pulsar_lb_bandwidth_in_usage")); assertTrue(metrics.containsKey("pulsar_lb_bandwidth_out_usage")); - assertTrue(metrics.containsKey("pulsar_lb_bundles_split_count")); + assertTrue(metrics.containsKey("pulsar_lb_bundles_split_total")); } @Test diff --git a/site2/docs/reference-metrics.md b/site2/docs/reference-metrics.md index 1ac4afd3dc0ef..ec978f877c49a 100644 --- a/site2/docs/reference-metrics.md +++ b/site2/docs/reference-metrics.md @@ -381,19 +381,19 @@ All the bundleUnloading metrics are labelled with the following labels: - cluster: cluster=${pulsar_cluster}. ${pulsar_cluster} is the cluster name that you have configured in the `broker.conf` file. - metric: metric="bundleUnloading". -| Name | Type | Description | -| --- | --- | --- | -| pulsar_lb_unload_broker_count | Counter | Unload broker count in this bundle unloading | -| pulsar_lb_unload_bundle_count | Counter | Bundle unload count in this bundle unloading | +| Name | Type | Description | +|-------------------------------|---------|----------------------------------------------| +| pulsar_lb_unload_broker_total | Counter | Unload broker count in this bundle unloading | +| pulsar_lb_unload_bundle_total | Counter | Bundle unload count in this bundle unloading | #### BundleSplit metrics All the bundleUnloading metrics are labelled with the following labels: - cluster: cluster=${pulsar_cluster}. ${pulsar_cluster} is the cluster name that you have configured in the `broker.conf` file. - metric: metric="bundlesSplit". -| Name | Type | Description | -| --- | --- | --- | -| pulsar_lb_bundles_split_count | Counter | bundle split count in this bundle splitting check interval | +| Name | Type | Description | +|-------------------------------|---------|------------------------------------------------------------| +| pulsar_lb_bundles_split_total | Counter | bundle split count in this bundle splitting check interval | #### Bundle metrics All the bundle metrics are labelled with the following labels: