From 89fd77ea951688117daa14cb39d18b227f13e331 Mon Sep 17 00:00:00 2001 From: abhilak Date: Wed, 3 Jun 2015 17:07:19 -0700 Subject: [PATCH] Evict count bug patch --- .../org/apache/hadoop/hbase/regionserver/HeapMemoryManager.java | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HeapMemoryManager.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HeapMemoryManager.java index a66a29c..4848547 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HeapMemoryManager.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HeapMemoryManager.java @@ -216,7 +216,9 @@ public class HeapMemoryManager { private HeapMemoryTuner heapMemTuner; private AtomicLong blockedFlushCount = new AtomicLong(); private AtomicLong unblockedFlushCount = new AtomicLong(); - private long evictCount = 0L; + private long lastEvictCount = 0L; + private long curEvictCount; + private long evictCount; private TunerContext tunerContext = new TunerContext(); private boolean alarming = false; @@ -264,7 +266,9 @@ public class HeapMemoryManager { } private void tune() { - evictCount = blockCache.getStats().getEvictedCount() - evictCount; + curEvictCount = blockCache.getStats().getEvictedCount(); + evictCount = curEvictCount - lastEvictCount; + lastEvictCount = curEvictCount; tunerContext.setBlockedFlushCount(blockedFlushCount.getAndSet(0)); tunerContext.setUnblockedFlushCount(unblockedFlushCount.getAndSet(0)); tunerContext.setEvictCount(evictCount); -- 1.9.5