diff --git a/client/src/main/java/io/streamnative/oxia/client/AsyncOxiaClientImpl.java b/client/src/main/java/io/streamnative/oxia/client/AsyncOxiaClientImpl.java index ccce47a4..83aa796d 100644 --- a/client/src/main/java/io/streamnative/oxia/client/AsyncOxiaClientImpl.java +++ b/client/src/main/java/io/streamnative/oxia/client/AsyncOxiaClientImpl.java @@ -682,7 +682,7 @@ public void onNext(long shardId, GetResult result) { @Override public void onError(Throwable throwable) { - gaugePendingListRequests.decrement(); + gaugePendingRangeScanRequests.decrement(); histogramRangeScanLatency.recordFailure(System.nanoTime() - startTime); consumer.onError(throwable); }