Skip to content

Commit 64ad12c

Browse files
authored
[metric] Update metric group infix to meet document (#1942)
1 parent 49dde59 commit 64ad12c

File tree

1 file changed

+2
-4
lines changed

1 file changed

+2
-4
lines changed

fluss-server/src/main/java/org/apache/fluss/server/metrics/group/TabletServerMetricGroup.java

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,6 @@
2929
import org.apache.fluss.metrics.SimpleCounter;
3030
import org.apache.fluss.metrics.ThreadSafeSimpleCounter;
3131
import org.apache.fluss.metrics.groups.AbstractMetricGroup;
32-
import org.apache.fluss.metrics.groups.MetricGroup;
3332
import org.apache.fluss.metrics.registry.MetricRegistry;
3433
import org.apache.fluss.utils.MapUtils;
3534

@@ -107,12 +106,11 @@ public TabletServerMetricGroup(
107106
bytesOut = new ThreadSafeSimpleCounter();
108107
meter(MetricNames.BYTES_OUT_RATE, new MeterView(bytesOut));
109108

110-
MetricGroup logMetricGroup = this.addGroup("log");
111109
// about flush
112110
logFlushCount = new SimpleCounter();
113-
logMetricGroup.meter(MetricNames.LOG_FLUSH_RATE, new MeterView(logFlushCount));
111+
meter(MetricNames.LOG_FLUSH_RATE, new MeterView(logFlushCount));
114112
logFlushLatencyHistogram = new DescriptiveStatisticsHistogram(WINDOW_SIZE);
115-
logMetricGroup.histogram(MetricNames.LOG_FLUSH_LATENCY_MS, logFlushLatencyHistogram);
113+
histogram(MetricNames.LOG_FLUSH_LATENCY_MS, logFlushLatencyHistogram);
116114

117115
// about pre-write buffer.
118116
kvFlushCount = new SimpleCounter();

0 commit comments

Comments
 (0)