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();