Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-21639 maxHeapUsage value not read properly from config during EntryBuffers initialization

This commit is contained in:
Pankaj 2018-12-29 00:54:48 +05:30 committed by stack
parent bc0fb66e22
commit 6da0b4ec34
2 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/RegionReplicaReplicationEndpoint.java
View File

@ -132,8 +132,7 @@ public class RegionReplicaReplicationEndpoint extends HBaseReplicationEndpoint {
"hbase.region.replica.replication.writer.threads", 3); "hbase.region.replica.replication.writer.threads", 3);
controller = new PipelineController(); controller = new PipelineController();
entryBuffers = new EntryBuffers(controller, entryBuffers = new EntryBuffers(controller,
this.conf.getInt("hbase.region.replica.replication.buffersize", this.conf.getLong("hbase.region.replica.replication.buffersize", 128 * 1024 * 1024));
128*1024*1024));
// use the regular RPC timeout for replica replication RPC's // use the regular RPC timeout for replica replication RPC's
this.operationTimeout = conf.getInt(HConstants.HBASE_CLIENT_OPERATION_TIMEOUT, this.operationTimeout = conf.getInt(HConstants.HBASE_CLIENT_OPERATION_TIMEOUT,

2
hbase-server/src/main/java/org/apache/hadoop/hbase/wal/WALSplitter.java
View File

@ -167,7 +167,7 @@ public class WALSplitter {
this.splitWriterCreationBounded = conf.getBoolean(SPLIT_WRITER_CREATION_BOUNDED, false); this.splitWriterCreationBounded = conf.getBoolean(SPLIT_WRITER_CREATION_BOUNDED, false);
entryBuffers = new EntryBuffers(controller, entryBuffers = new EntryBuffers(controller,
this.conf.getInt("hbase.regionserver.hlog.splitlog.buffersize", 128 * 1024 * 1024), this.conf.getLong("hbase.regionserver.hlog.splitlog.buffersize", 128 * 1024 * 1024),
splitWriterCreationBounded); splitWriterCreationBounded);
int numWriterThreads = this.conf.getInt("hbase.regionserver.hlog.splitlog.writer.threads", 3); int numWriterThreads = this.conf.getInt("hbase.regionserver.hlog.splitlog.writer.threads", 3);