diff --git a/src/java/org/apache/hadoop/hbase/regionserver/HLog.java b/src/java/org/apache/hadoop/hbase/regionserver/HLog.java index 0ef3cfa..4526013 100644 --- a/src/java/org/apache/hadoop/hbase/regionserver/HLog.java +++ b/src/java/org/apache/hadoop/hbase/regionserver/HLog.java @@ -124,6 +124,7 @@ public class HLog implements HConstants, Syncable { private volatile long lastLogFlushTime; private final boolean append; private final Method syncfs; + private final short replicationLevel; private final static Object [] NO_ARGS = new Object []{}; /* @@ -208,9 +209,11 @@ public class HLog implements HConstants, Syncable { this.conf = conf; this.listener = listener; this.flushlogentries = - conf.getInt("hbase.regionserver.flushlogentries", 100); + conf.getInt("hbase.regionserver.flus hlogentries", 100); this.blocksize = conf.getLong("hbase.regionserver.hlog.blocksize", this.fs.getDefaultBlockSize()); + this.replicationLevel = (short) conf.getInt("hbase.regionserver.hlog.replication", + this.fs.getDefaultReplication()); // Roll at 95% of block size. float multi = conf.getFloat("hbase.regionserver.logroll.multiplier", 0.95f); this.logrollsize = (long)(this.blocksize * multi); @@ -442,7 +445,7 @@ public class HLog implements HConstants, Syncable { SequenceFile.Writer writer = SequenceFile.createWriter(this.fs, this.conf, path, keyClass, valueClass, fs.getConf().getInt("io.file.buffer.size", 4096), - fs.getDefaultReplication(), this.blocksize, + this.replicationLevel, this.blocksize, SequenceFile.CompressionType.NONE, new DefaultCodec(), null, new Metadata()); // Get at the private FSDataOutputStream inside in SequenceFile so we can