From c3463b4941ddf3cc0301127bc45a9cc0fb1e600c Mon Sep 17 00:00:00 2001 From: Shichao Nie Date: Wed, 17 Apr 2024 10:43:59 +0800 Subject: [PATCH] fix(metrics): fix method name (#1129) Signed-off-by: Shichao Nie --- s3stream/src/main/java/com/automq/stream/s3/S3Stream.java | 4 ++-- .../com/automq/stream/s3/metrics/S3StreamMetricsManager.java | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/s3stream/src/main/java/com/automq/stream/s3/S3Stream.java b/s3stream/src/main/java/com/automq/stream/s3/S3Stream.java index 42cdefcdf3..742f915068 100644 --- a/s3stream/src/main/java/com/automq/stream/s3/S3Stream.java +++ b/s3stream/src/main/java/com/automq/stream/s3/S3Stream.java @@ -347,8 +347,8 @@ public CompletableFuture close() { LOGGER.info("{} closed", logIdent); StreamOperationStats.getInstance().closeStreamStats(true).record(timerUtil.elapsedAs(TimeUnit.NANOSECONDS)); } - S3StreamMetricsManager.removePendingStreamAppendNumSupplier(streamId); - S3StreamMetricsManager.removePendingStreamFetchNumSupplier(streamId); + S3StreamMetricsManager.removePendingStreamAppendLatencySupplier(streamId); + S3StreamMetricsManager.removePendingStreamFetchLatencySupplier(streamId); }); return closeCf; diff --git a/s3stream/src/main/java/com/automq/stream/s3/metrics/S3StreamMetricsManager.java b/s3stream/src/main/java/com/automq/stream/s3/metrics/S3StreamMetricsManager.java index 514bb58ad5..74f91986a4 100644 --- a/s3stream/src/main/java/com/automq/stream/s3/metrics/S3StreamMetricsManager.java +++ b/s3stream/src/main/java/com/automq/stream/s3/metrics/S3StreamMetricsManager.java @@ -586,11 +586,11 @@ public static void registerPendingStreamFetchLatencySupplier(long streamId, Supp S3StreamMetricsManager.pendingStreamFetchLatencySupplier.put(streamId, pendingStreamFetchLatencySupplier); } - public static void removePendingStreamAppendNumSupplier(long streamId) { + public static void removePendingStreamAppendLatencySupplier(long streamId) { S3StreamMetricsManager.pendingStreamAppendLatencySupplier.remove(streamId); } - public static void removePendingStreamFetchNumSupplier(long streamId) { + public static void removePendingStreamFetchLatencySupplier(long streamId) { S3StreamMetricsManager.pendingStreamFetchLatencySupplier.remove(streamId); }