From 6f8691fad3ddfce15116db9085e9b041f53d63f5 Mon Sep 17 00:00:00 2001
From: liever18 <1056353055@qq.com>
Date: Thu, 29 Jul 2021 10:26:59 +0800
Subject: [PATCH] =?UTF-8?q?[HBASE-26114][master]when=20=E2=80=9Chbase.mob.?=
 =?UTF-8?q?compaction.threads.max=E2=80=9D=20is=20set=20to=20a=20negative?=
 =?UTF-8?q?=20number,=20HMaster=20cannot=20start=20normally?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

improve the handling mechanism for the user to set hbase.mob.compaction.threads.max as an abnormal value.
---
 .../src/main/java/org/apache/hadoop/hbase/mob/MobUtils.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/mob/MobUtils.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/mob/MobUtils.java
index 2a6e6376ed9a..106775075bfd 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/mob/MobUtils.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/mob/MobUtils.java
@@ -863,7 +863,7 @@ public static void doMobCompaction(Configuration conf, FileSystem fs, TableName
   public static ExecutorService createMobCompactorThreadPool(Configuration conf) {
     int maxThreads = conf.getInt(MobConstants.MOB_COMPACTION_THREADS_MAX,
         MobConstants.DEFAULT_MOB_COMPACTION_THREADS_MAX);
-    if (maxThreads == 0) {
+    if (maxThreads <= 0) {
       maxThreads = 1;
     }
     final SynchronousQueue<Runnable> queue = new SynchronousQueue<>();