hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From st...@apache.org
Subject hbase git commit: HBASE-15385 PREFETCH_BLOCKS_ON_OPEN in HColumnDescriptor is ignored
Date Wed, 20 Apr 2016 16:43:59 GMT
Repository: hbase
Updated Branches:
  refs/heads/branch-1.2 c86d17d41 -> b2e0008cf


HBASE-15385 PREFETCH_BLOCKS_ON_OPEN in HColumnDescriptor is ignored


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

Branch: refs/heads/branch-1.2
Commit: b2e0008cf34aaf6a41beff85c342b835493908f0
Parents: c86d17d
Author: stack <stack@apache.org>
Authored: Wed Apr 20 09:43:52 2016 -0700
Committer: stack <stack@apache.org>
Committed: Wed Apr 20 09:43:52 2016 -0700

----------------------------------------------------------------------
 .../java/org/apache/hadoop/hbase/io/hfile/CacheConfig.java    | 7 +++++--
 .../java/org/apache/hadoop/hbase/io/hfile/HFileReaderV2.java  | 6 +++---
 2 files changed, 8 insertions(+), 5 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hbase/blob/b2e0008c/hbase-server/src/main/java/org/apache/hadoop/hbase/io/hfile/CacheConfig.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/io/hfile/CacheConfig.java
b/hbase-server/src/main/java/org/apache/hadoop/hbase/io/hfile/CacheConfig.java
index 2b76b88..e79ba35 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/io/hfile/CacheConfig.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/io/hfile/CacheConfig.java
@@ -232,11 +232,14 @@ public class CacheConfig {
             HColumnDescriptor.DEFAULT_CACHE_DATA_IN_L1) || family.isCacheDataInL1(),
         conf.getBoolean(DROP_BEHIND_CACHE_COMPACTION_KEY,DROP_BEHIND_CACHE_COMPACTION_DEFAULT)
      );
+    LOG.info("Created cacheConfig for " + family.getNameAsString() + ": " + this);
   }
 
   /**
    * Create a cache configuration using the specified configuration object and
-   * defaults for family level settings.
+   * defaults for family level settings. Only use if no column family context. Prefer
+   * {@link CacheConfig#CacheConfig(Configuration, HColumnDescriptor)}
+   * @see #CacheConfig(Configuration, HColumnDescriptor)
    * @param conf hbase configuration
    */
   public CacheConfig(Configuration conf) {
@@ -254,6 +257,7 @@ public class CacheConfig {
           HColumnDescriptor.DEFAULT_CACHE_DATA_IN_L1),
         conf.getBoolean(DROP_BEHIND_CACHE_COMPACTION_KEY,DROP_BEHIND_CACHE_COMPACTION_DEFAULT)
      );
+    LOG.info("Created cacheConfig: " + this);
   }
 
   /**
@@ -289,7 +293,6 @@ public class CacheConfig {
     this.prefetchOnOpen = prefetchOnOpen;
     this.cacheDataInL1 = cacheDataInL1;
     this.dropBehindCompaction = dropBehindCompaction;
-    LOG.info(this);
   }
 
   /**

http://git-wip-us.apache.org/repos/asf/hbase/blob/b2e0008c/hbase-server/src/main/java/org/apache/hadoop/hbase/io/hfile/HFileReaderV2.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/io/hfile/HFileReaderV2.java
b/hbase-server/src/main/java/org/apache/hadoop/hbase/io/hfile/HFileReaderV2.java
index a1b4c34..e0ae9ca 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/io/hfile/HFileReaderV2.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/io/hfile/HFileReaderV2.java
@@ -195,7 +195,7 @@ public class HFileReaderV2 extends AbstractHFileReader {
             end = getTrailer().getLoadOnOpenDataOffset();
             HFileBlock prevBlock = null;
             if (LOG.isTraceEnabled()) {
-              LOG.trace("File=" + path.toString() + ", offset=" + offset + ", end=" + end);
+              LOG.trace("Prefetch=" + path.toString() + ", offset=" + offset + ", end=" +
end);
             }
             while (offset < end) {
               if (Thread.interrupted()) {
@@ -213,11 +213,11 @@ public class HFileReaderV2 extends AbstractHFileReader {
           } catch (IOException e) {
             // IOExceptions are probably due to region closes (relocation, etc.)
             if (LOG.isTraceEnabled()) {
-              LOG.trace("File=" + path.toString() + ", offset=" + offset + ", end=" + end,
e);
+              LOG.trace("Prefetch=" + path.toString() + ", offset=" + offset + ", end=" +
end, e);
             }
           } catch (Exception e) {
             // Other exceptions are interesting
-            LOG.warn("File=" + path.toString() + ", offset=" + offset + ", end=" + end, e);
+            LOG.warn("Prefetch=" + path.toString() + ", offset=" + offset + ", end=" + end,
e);
           } finally {
             PrefetchExecutor.complete(path);
           }


Mime
View raw message