From 1ad5d579d3263bd334c8b350dace6df777536dcf Mon Sep 17 00:00:00 2001
From: xcang <xcang@salesforce.com>
Date: Thu, 6 Sep 2018 00:54:31 -0700
Subject: [PATCH] HBASE-15728 (addendum) Add remaining per-table region / store
 / flush / compaction related metrics

Signed-off-by: Guanghao Zhang <zghao@apache.org>
---
 .../hbase/regionserver/MetricsTableSourceImpl.java | 14 +++++++-------
 1 file changed, 7 insertions(+), 7 deletions(-)

diff --git a/hbase-hadoop2-compat/src/main/java/org/apache/hadoop/hbase/regionserver/MetricsTableSourceImpl.java b/hbase-hadoop2-compat/src/main/java/org/apache/hadoop/hbase/regionserver/MetricsTableSourceImpl.java
index 08074790f92..d65c446b3ef 100644
--- a/hbase-hadoop2-compat/src/main/java/org/apache/hadoop/hbase/regionserver/MetricsTableSourceImpl.java
+++ b/hbase-hadoop2-compat/src/main/java/org/apache/hadoop/hbase/regionserver/MetricsTableSourceImpl.java
@@ -364,19 +364,19 @@ public class MetricsTableSourceImpl implements MetricsTableSource {
   }
 
   @Override
-  public void updateFlushMemstoreSize(long bytes) {
+  public synchronized void updateFlushMemstoreSize(long bytes) {
     flushMemstoreSizeHisto.add(bytes);
     flushedMemstoreBytes.incr(bytes);
   }
 
   @Override
-  public void updateFlushOutputSize(long bytes) {
+  public synchronized void updateFlushOutputSize(long bytes) {
     flushOutputSizeHisto.add(bytes);
     flushedOutputBytes.incr(bytes);
   }
 
   @Override
-  public void updateCompactionTime(boolean isMajor, long t) {
+  public synchronized void updateCompactionTime(boolean isMajor, long t) {
     compactionTimeHisto.add(t);
     if (isMajor) {
       majorCompactionTimeHisto.add(t);
@@ -384,7 +384,7 @@ public class MetricsTableSourceImpl implements MetricsTableSource {
   }
 
   @Override
-  public void updateCompactionInputFileCount(boolean isMajor, long c) {
+  public synchronized void updateCompactionInputFileCount(boolean isMajor, long c) {
     compactionInputFileCountHisto.add(c);
     if (isMajor) {
       majorCompactionInputFileCountHisto.add(c);
@@ -392,7 +392,7 @@ public class MetricsTableSourceImpl implements MetricsTableSource {
   }
 
   @Override
-  public void updateCompactionInputSize(boolean isMajor, long bytes) {
+  public synchronized void updateCompactionInputSize(boolean isMajor, long bytes) {
     compactionInputSizeHisto.add(bytes);
     compactedInputBytes.incr(bytes);
     if (isMajor) {
@@ -402,7 +402,7 @@ public class MetricsTableSourceImpl implements MetricsTableSource {
   }
 
   @Override
-  public void updateCompactionOutputFileCount(boolean isMajor, long c) {
+  public synchronized void updateCompactionOutputFileCount(boolean isMajor, long c) {
     compactionOutputFileCountHisto.add(c);
     if (isMajor) {
       majorCompactionOutputFileCountHisto.add(c);
@@ -410,7 +410,7 @@ public class MetricsTableSourceImpl implements MetricsTableSource {
   }
 
   @Override
-  public void updateCompactionOutputSize(boolean isMajor, long bytes) {
+  public synchronized void updateCompactionOutputSize(boolean isMajor, long bytes) {
     compactionOutputSizeHisto.add(bytes);
     compactedOutputBytes.incr(bytes);
     if (isMajor) {