This is an automated email from the ASF dual-hosted git repository.

yunhong pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/fluss.git


The following commit(s) were added to refs/heads/main by this push:
     new 64ad12c0c [metric] Update metric group infix to meet document (#1942)
64ad12c0c is described below

commit 64ad12c0c1d53a7164c9537d0d0f0fd660ad784a
Author: xiaozhou <[email protected]>
AuthorDate: Fri Nov 7 16:42:15 2025 +0800

    [metric] Update metric group infix to meet document (#1942)
---
 .../apache/fluss/server/metrics/group/TabletServerMetricGroup.java  | 6 ++----
 1 file changed, 2 insertions(+), 4 deletions(-)

diff --git 
a/fluss-server/src/main/java/org/apache/fluss/server/metrics/group/TabletServerMetricGroup.java
 
b/fluss-server/src/main/java/org/apache/fluss/server/metrics/group/TabletServerMetricGroup.java
index cb1b75ff3..59730b69f 100644
--- 
a/fluss-server/src/main/java/org/apache/fluss/server/metrics/group/TabletServerMetricGroup.java
+++ 
b/fluss-server/src/main/java/org/apache/fluss/server/metrics/group/TabletServerMetricGroup.java
@@ -29,7 +29,6 @@ import org.apache.fluss.metrics.MetricNames;
 import org.apache.fluss.metrics.SimpleCounter;
 import org.apache.fluss.metrics.ThreadSafeSimpleCounter;
 import org.apache.fluss.metrics.groups.AbstractMetricGroup;
-import org.apache.fluss.metrics.groups.MetricGroup;
 import org.apache.fluss.metrics.registry.MetricRegistry;
 import org.apache.fluss.utils.MapUtils;
 
@@ -107,12 +106,11 @@ public class TabletServerMetricGroup extends 
AbstractMetricGroup {
         bytesOut = new ThreadSafeSimpleCounter();
         meter(MetricNames.BYTES_OUT_RATE, new MeterView(bytesOut));
 
-        MetricGroup logMetricGroup = this.addGroup("log");
         // about flush
         logFlushCount = new SimpleCounter();
-        logMetricGroup.meter(MetricNames.LOG_FLUSH_RATE, new 
MeterView(logFlushCount));
+        meter(MetricNames.LOG_FLUSH_RATE, new MeterView(logFlushCount));
         logFlushLatencyHistogram = new 
DescriptiveStatisticsHistogram(WINDOW_SIZE);
-        logMetricGroup.histogram(MetricNames.LOG_FLUSH_LATENCY_MS, 
logFlushLatencyHistogram);
+        histogram(MetricNames.LOG_FLUSH_LATENCY_MS, logFlushLatencyHistogram);
 
         // about pre-write buffer.
         kvFlushCount = new SimpleCounter();

Reply via email to