You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@bookkeeper.apache.org by lu...@apache.org on 2023/02/13 04:02:58 UTC
[bookkeeper] branch master updated: Remove duplicated JournalQueueStats (#3753)
This is an automated email from the ASF dual-hosted git repository.
lushiji pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/bookkeeper.git
The following commit(s) were added to refs/heads/master by this push:
new b9a82c54c7 Remove duplicated JournalQueueStats (#3753)
b9a82c54c7 is described below
commit b9a82c54c75108662d35c7bfef075e8e971cb2f7
Author: houxiaoyu <ho...@apache.org>
AuthorDate: Mon Feb 13 12:02:51 2023 +0800
Remove duplicated JournalQueueStats (#3753)
---
.../src/main/java/org/apache/bookkeeper/bookie/Journal.java | 4 ----
1 file changed, 4 deletions(-)
diff --git a/bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/Journal.java b/bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/Journal.java
index 3942e7662a..737893aade 100644
--- a/bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/Journal.java
+++ b/bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/Journal.java
@@ -1136,10 +1136,6 @@ public class Journal extends BookieCriticalThread implements CheckpointSource {
qe = localQueueEntries.removeFirst();
dequeueStartTime = MathUtils.nowInNano();
busyStartTime = dequeueStartTime;
- journalStats.getJournalQueueSize().dec();
- journalStats.getJournalQueueStats()
- .registerSuccessfulEvent(MathUtils.elapsedNanos(qe.enqueueTime),
- TimeUnit.NANOSECONDS);
} else {
long pollWaitTimeNanos = maxGroupWaitInNanos
- MathUtils.elapsedNanos(toFlush.get(0).enqueueTime);