diff --git hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java index b583e0e..ea53b1f 100644 --- hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java +++ hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java @@ -520,7 +520,7 @@ public class HRegionServer extends HasThread implements FSUtils.setupShortCircuitRead(this.conf); // Disable usage of meta replicas in the regionserver this.conf.setBoolean(HConstants.USE_META_REPLICAS, false); - + decorateHdfsConfig(); // Config'ed params this.numRetries = this.conf.getInt(HConstants.HBASE_CLIENT_RETRIES_NUMBER, HConstants.DEFAULT_HBASE_CLIENT_RETRIES_NUMBER); @@ -641,6 +641,15 @@ public class HRegionServer extends HasThread implements choreService.scheduleChore(compactedFileDischarger); } + /** + * HDFS clinet configuration options + */ + private void decorateHdfsConfig() { + if(this.conf.get("dfs.client.write.byte-array-manager.enabled") == null){ + this.conf.setBoolean("dfs.client.write.byte-array-manager.enabled", true); + } + } + protected TableDescriptors getFsTableDescriptors() throws IOException { return new FSTableDescriptors(this.conf, this.fs, this.rootDir, !canUpdateTableDescriptor(), false);