HBASE-11279 Block cache could be disabled by mistake
This commit is contained in:
parent
bdfb4172f8
commit
369141b795
|
@ -423,7 +423,8 @@ public class CacheConfig {
|
|||
static BlockCache GLOBAL_BLOCK_CACHE_INSTANCE;
|
||||
|
||||
/** Boolean whether we have disabled the block cache entirely. */
|
||||
private static boolean blockCacheDisabled = false;
|
||||
@VisibleForTesting
|
||||
static boolean blockCacheDisabled = false;
|
||||
|
||||
/**
|
||||
* Returns the block cache or <code>null</code> in case none should be used.
|
||||
|
@ -437,7 +438,7 @@ public class CacheConfig {
|
|||
|
||||
float cachePercentage = conf.getFloat(HConstants.HFILE_BLOCK_CACHE_SIZE_KEY,
|
||||
HConstants.HFILE_BLOCK_CACHE_SIZE_DEFAULT);
|
||||
if (cachePercentage == 0L) {
|
||||
if (cachePercentage <= 0.0001f) {
|
||||
blockCacheDisabled = true;
|
||||
return null;
|
||||
}
|
||||
|
|
|
@ -57,6 +57,7 @@ public class TestPrefetch {
|
|||
conf.setInt(HFile.FORMAT_VERSION_KEY, 3);
|
||||
conf.setBoolean(CacheConfig.PREFETCH_BLOCKS_ON_OPEN_KEY, true);
|
||||
fs = HFileSystem.get(conf);
|
||||
CacheConfig.blockCacheDisabled = false;
|
||||
cacheConf = new CacheConfig(conf);
|
||||
}
|
||||
|
||||
|
|
|
@ -53,7 +53,7 @@ import org.junit.runners.Parameterized.Parameters;
|
|||
@RunWith(Parameterized.class)
|
||||
@Category(SmallTests.class)
|
||||
public class TestScannerSelectionUsingKeyRange {
|
||||
private static final HBaseTestingUtility TEST_UTIL = new HBaseTestingUtility().createLocalHTU();
|
||||
private static final HBaseTestingUtility TEST_UTIL = HBaseTestingUtility.createLocalHTU();
|
||||
private static TableName TABLE = TableName.valueOf("myTable");
|
||||
private static String FAMILY = "myCF";
|
||||
private static byte[] FAMILY_BYTES = Bytes.toBytes(FAMILY);
|
||||
|
@ -113,6 +113,7 @@ public class TestScannerSelectionUsingKeyRange {
|
|||
}
|
||||
|
||||
Scan scan = new Scan(Bytes.toBytes("aaa"), Bytes.toBytes("aaz"));
|
||||
CacheConfig.blockCacheDisabled = false;
|
||||
CacheConfig cacheConf = new CacheConfig(conf);
|
||||
LruBlockCache cache = (LruBlockCache) cacheConf.getBlockCache();
|
||||
cache.clearCache();
|
||||
|
|
Loading…
Reference in New Issue