This is an automated email from the ASF dual-hosted git repository. zghao pushed a commit to branch branch-2.3 in repository https://gitbox.apache.org/repos/asf/hbase.git
The following commit(s) were added to refs/heads/branch-2.3 by this push: new 20557c0 HBASE-23702 hbase.hstore.flusher.count setting to 0 breaks HMaster (#1703) 20557c0 is described below commit 20557c05105e95b79f3deb2ae4741c8f1be81200 Author: Guanghao Zhang <zg...@apache.org> AuthorDate: Fri May 15 09:05:25 2020 +0800 HBASE-23702 hbase.hstore.flusher.count setting to 0 breaks HMaster (#1703) Co-authored-by: Ctest Signed-off-by: Anoop Sam John <anoop.hb...@gmail.com> Signed-off-by: Wellington Chevreuil <wchevre...@apache.org> --- .../java/org/apache/hadoop/hbase/regionserver/MemStoreFlusher.java | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreFlusher.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreFlusher.java index 39b0368..fcff217 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreFlusher.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreFlusher.java @@ -128,6 +128,11 @@ class MemStoreFlusher implements FlushRequester { this.blockingWaitTime = conf.getInt("hbase.hstore.blockingWaitTime", 90000); int handlerCount = conf.getInt("hbase.hstore.flusher.count", 2); + if (handlerCount < 1) { + LOG.warn("hbase.hstore.flusher.count was configed to {} which is less than 1, corrected to 1", + handlerCount); + handlerCount = 1; + } this.flushHandlers = new FlushHandler[handlerCount]; LOG.info("globalMemStoreLimit=" + TraditionalBinaryPrefix