hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From anoopsamj...@apache.org
Subject hbase git commit: HBASE-12591 Ignore the count of mob compaction metrics when there is issue.(Jiajia Li)
Date Tue, 02 Dec 2014 01:45:04 GMT
Repository: hbase
Updated Branches:
  refs/heads/hbase-11339 10e4ef740 -> 33fc1918d


HBASE-12591 Ignore the count of mob compaction metrics when there is issue.(Jiajia Li)


Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/33fc1918
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/33fc1918
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/33fc1918

Branch: refs/heads/hbase-11339
Commit: 33fc1918dea9a73e5bc4300db927d419016542f9
Parents: 10e4ef7
Author: anoopsjohn <anoopsamjohn@gmail.com>
Authored: Tue Dec 2 07:14:39 2014 +0530
Committer: anoopsjohn <anoopsamjohn@gmail.com>
Committed: Tue Dec 2 07:14:39 2014 +0530

----------------------------------------------------------------------
 .../java/org/apache/hadoop/hbase/mob/DefaultMobCompactor.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hbase/blob/33fc1918/hbase-server/src/main/java/org/apache/hadoop/hbase/mob/DefaultMobCompactor.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/mob/DefaultMobCompactor.java
b/hbase-server/src/main/java/org/apache/hadoop/hbase/mob/DefaultMobCompactor.java
index c84ed82..d0c8175 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/mob/DefaultMobCompactor.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/mob/DefaultMobCompactor.java
@@ -171,14 +171,14 @@ public class DefaultMobCompactor extends DefaultCompactor {
                   KeyValue mobKv = KeyValueUtil.ensureKeyValue(cell);
                   mobKv.setSequenceId(kv.getSequenceId());
                   writer.append(mobKv);
+                  mobCompactedFromMobCellsCount++;
+                  mobCompactedFromMobCellsSize += cell.getValueLength();
                 } else {
                   // If the value of a file is empty, there might be issues when retrieving,
                   // directly write the cell to the store file, and leave it to be handled
by the
                   // next compaction.
                   writer.append(kv);
                 }
-                mobCompactedFromMobCellsCount++;
-                mobCompactedFromMobCellsSize += cell.getValueLength();
               }
             } else {
               LOG.warn("The value format of the KeyValue " + kv


Mime
View raw message