From 9192304b30f33e4c92a9184eb0272536993c2dab Mon Sep 17 00:00:00 2001 From: anastas Date: Thu, 30 Mar 2017 14:49:35 +0300 Subject: [PATCH] Changing CompactingMemStore default policy to be BASIC that includes merging of the segments in pipeline --- .../java/org/apache/hadoop/hbase/regionserver/CompactingMemStore.java | 2 +- .../java/org/apache/hadoop/hbase/regionserver/MemStoreCompactor.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/CompactingMemStore.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/CompactingMemStore.java index 0c56693..85d1866 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/CompactingMemStore.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/CompactingMemStore.java @@ -56,7 +56,7 @@ public class CompactingMemStore extends AbstractMemStore { public static final String COMPACTING_MEMSTORE_TYPE_KEY = "hbase.hregion.compacting.memstore.type"; public static final String COMPACTING_MEMSTORE_TYPE_DEFAULT = - String.valueOf(MemoryCompactionPolicy.NONE); + String.valueOf(MemoryCompactionPolicy.BASIC); // Default fraction of in-memory-flush size w.r.t. flush-to-disk size public static final String IN_MEMORY_FLUSH_THRESHOLD_FACTOR_KEY = "hbase.memstore.inmemoryflush.threshold.factor"; diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreCompactor.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreCompactor.java index 0d3f47e..08af7fe 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreCompactor.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreCompactor.java @@ -50,7 +50,7 @@ public class MemStoreCompactor { public static final String COMPACTING_MEMSTORE_THRESHOLD_KEY = "hbase.hregion.compacting.pipeline.segments.limit"; // remaining with the same ("infinity") but configurable default for now - public static final int COMPACTING_MEMSTORE_THRESHOLD_DEFAULT = 30; + public static final int COMPACTING_MEMSTORE_THRESHOLD_DEFAULT = 1; public static final long DEEP_OVERHEAD = ClassSize .align(ClassSize.OBJECT -- 1.8.5.2 (Apple Git-48)