diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/cleaner/LogCleaner.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/cleaner/LogCleaner.java index 6ede2b50d8a3..2b676e3ba9d6 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/cleaner/LogCleaner.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/cleaner/LogCleaner.java @@ -100,6 +100,13 @@ protected boolean validate(Path file) { @Override public void onConfigurationChange(Configuration conf) { int newSize = conf.getInt(OLD_WALS_CLEANER_THREAD_SIZE, DEFAULT_OLD_WALS_CLEANER_THREAD_SIZE); + if (newSize <= 0) { + LOG.debug( + "The configuration {} has been set to an invalid value {}, " + + "the previous value {} will be used, no need to update.", + OLD_WALS_CLEANER_THREAD_SIZE, newSize, oldWALsCleaner.size()); + return; + } if (newSize == oldWALsCleaner.size()) { LOG.debug( "Size from configuration is the same as previous which " + "is {}, no need to update.",