You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by la...@apache.org on 2014/12/30 05:39:57 UTC

[2/2] hbase git commit: HBASE-12776 SpliTransaction: Log number of files to be split.

HBASE-12776 SpliTransaction: Log number of files to be split.


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

Branch: refs/heads/branch-1
Commit: 6a7c619e1e841dad5b570a269d05cabca88e6232
Parents: 619f94f
Author: Lars Hofhansl <la...@apache.org>
Authored: Mon Dec 29 20:38:09 2014 -0800
Committer: Lars Hofhansl <la...@apache.org>
Committed: Mon Dec 29 20:38:33 2014 -0800

----------------------------------------------------------------------
 .../org/apache/hadoop/hbase/regionserver/SplitTransaction.java  | 5 +++++
 1 file changed, 5 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hbase/blob/6a7c619e/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/SplitTransaction.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/SplitTransaction.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/SplitTransaction.java
index 06e726f..292da33 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/SplitTransaction.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/SplitTransaction.java
@@ -697,6 +697,7 @@ public class SplitTransaction {
       // no file needs to be splitted.
       return new Pair<Integer, Integer>(0,0);
     }
+    LOG.info("Preparing to split " + nbFiles + " storefiles for region " + this.parent);
     ThreadFactoryBuilder builder = new ThreadFactoryBuilder();
     builder.setNameFormat("StoreFileSplitter-%1$d");
     ThreadFactory factory = builder.build();
@@ -746,6 +747,10 @@ public class SplitTransaction {
       }
     }
 
+    if (LOG.isDebugEnabled()) {
+      LOG.debug("Split storefiles for region " + this.parent + " Daugther A: " + created_a
+          + " storefiles, Daugther B: " + created_b + " storefiles.");
+    }
     return new Pair<Integer, Integer>(created_a, created_b);
   }