You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by st...@apache.org on 2019/01/15 20:18:39 UTC
[hbase] branch master updated: HBASE-21639 maxHeapUsage value not
read properly from config during EntryBuffers initialization
This is an automated email from the ASF dual-hosted git repository.
stack pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hbase.git
The following commit(s) were added to refs/heads/master by this push:
new 6da0b4e HBASE-21639 maxHeapUsage value not read properly from config during EntryBuffers initialization
6da0b4e is described below
commit 6da0b4ec34727240e433825382cfc30366340097
Author: Pankaj <pa...@huawei.com>
AuthorDate: Sat Dec 29 00:54:48 2018 +0530
HBASE-21639 maxHeapUsage value not read properly from config during EntryBuffers initialization
---
.../replication/regionserver/RegionReplicaReplicationEndpoint.java | 3 +--
.../src/main/java/org/apache/hadoop/hbase/wal/WALSplitter.java | 2 +-
2 files changed, 2 insertions(+), 3 deletions(-)
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/RegionReplicaReplicationEndpoint.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/RegionReplicaReplicationEndpoint.java
index dc83eb7..f7721e0 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/RegionReplicaReplicationEndpoint.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/RegionReplicaReplicationEndpoint.java
@@ -132,8 +132,7 @@ public class RegionReplicaReplicationEndpoint extends HBaseReplicationEndpoint {
"hbase.region.replica.replication.writer.threads", 3);
controller = new PipelineController();
entryBuffers = new EntryBuffers(controller,
- this.conf.getInt("hbase.region.replica.replication.buffersize",
- 128*1024*1024));
+ this.conf.getLong("hbase.region.replica.replication.buffersize", 128 * 1024 * 1024));
// use the regular RPC timeout for replica replication RPC's
this.operationTimeout = conf.getInt(HConstants.HBASE_CLIENT_OPERATION_TIMEOUT,
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/wal/WALSplitter.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/wal/WALSplitter.java
index bc67d98..6679597 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/wal/WALSplitter.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/wal/WALSplitter.java
@@ -167,7 +167,7 @@ public class WALSplitter {
this.splitWriterCreationBounded = conf.getBoolean(SPLIT_WRITER_CREATION_BOUNDED, false);
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);
int numWriterThreads = this.conf.getInt("hbase.regionserver.hlog.splitlog.writer.threads", 3);