diff --git a/src/java/org/apache/hadoop/hbase/regionserver/HLog.java b/src/java/org/apache/hadoop/hbase/regionserver/HLog.java index 819ba48..02ce596 100644 --- a/src/java/org/apache/hadoop/hbase/regionserver/HLog.java +++ b/src/java/org/apache/hadoop/hbase/regionserver/HLog.java @@ -116,6 +116,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 []{}; /* @@ -200,6 +201,8 @@ public class HLog implements HConstants, Syncable { conf.getInt("hbase.regionserver.flushlogentries", 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); @@ -351,8 +354,8 @@ public class HLog implements HConstants, Syncable { Class keyClass, Class valueClass) throws IOException { return SequenceFile.createWriter(this.fs, this.conf, path, keyClass, - valueClass, fs.getConf().getInt("io.file.buffer.size", 4096), fs - .getDefaultReplication(), this.blocksize, + valueClass, fs.getConf().getInt("io.file.buffer.size", 4096), + this.replicationLevel, this.blocksize, SequenceFile.CompressionType.NONE, new DefaultCodec(), null, new Metadata()); }