Skip to content

Commit 24823ec

Browse files
authored
HBASE-23682 Fix NPE when disable DeadServerMetricRegionChore (#1026)
Signed-off-by: Bharath Vissapragada <bharathv@apache.org>
1 parent 348ee59 commit 24823ec

File tree

2 files changed

+74
-2
lines changed

2 files changed

+74
-2
lines changed

hbase-procedure/src/main/java/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.java

Lines changed: 9 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -17,6 +17,7 @@
1717
*/
1818
package org.apache.hadoop.hbase.procedure2;
1919

20+
import edu.umd.cs.findbugs.annotations.Nullable;
2021
import java.io.IOException;
2122
import java.io.UncheckedIOException;
2223
import java.util.ArrayDeque;
@@ -732,7 +733,10 @@ public long getKeepAliveTime(final TimeUnit timeUnit) {
732733
* Add a chore procedure to the executor
733734
* @param chore the chore to add
734735
*/
735-
public void addChore(ProcedureInMemoryChore<TEnvironment> chore) {
736+
public void addChore(@Nullable ProcedureInMemoryChore<TEnvironment> chore) {
737+
if (chore == null) {
738+
return;
739+
}
736740
chore.setState(ProcedureState.WAITING_TIMEOUT);
737741
timeoutExecutor.add(chore);
738742
}
@@ -742,7 +746,10 @@ public void addChore(ProcedureInMemoryChore<TEnvironment> chore) {
742746
* @param chore the chore to remove
743747
* @return whether the chore is removed, or it will be removed later
744748
*/
745-
public boolean removeChore(ProcedureInMemoryChore<TEnvironment> chore) {
749+
public boolean removeChore(@Nullable ProcedureInMemoryChore<TEnvironment> chore) {
750+
if (chore == null) {
751+
return true;
752+
}
746753
chore.setState(ProcedureState.SUCCESS);
747754
return timeoutExecutor.remove(chore);
748755
}
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,65 @@
1+
/*
2+
* Licensed to the Apache Software Foundation (ASF) under one
3+
* or more contributor license agreements. See the NOTICE file
4+
* distributed with this work for additional information
5+
* regarding copyright ownership. The ASF licenses this file
6+
* to you under the Apache License, Version 2.0 (the
7+
* "License"); you may not use this file except in compliance
8+
* with the License. You may obtain a copy of the License at
9+
*
10+
* http://www.apache.org/licenses/LICENSE-2.0
11+
*
12+
* Unless required by applicable law or agreed to in writing, software
13+
* distributed under the License is distributed on an "AS IS" BASIS,
14+
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
15+
* See the License for the specific language governing permissions and
16+
* limitations under the License.
17+
*/
18+
package org.apache.hadoop.hbase.master.assignment;
19+
20+
import static org.junit.Assert.fail;
21+
import org.apache.hadoop.hbase.HBaseClassTestRule;
22+
import org.apache.hadoop.hbase.HBaseTestingUtility;
23+
import org.apache.hadoop.hbase.testclassification.MasterTests;
24+
import org.apache.hadoop.hbase.testclassification.MediumTests;
25+
import org.junit.After;
26+
import org.junit.Before;
27+
import org.junit.ClassRule;
28+
import org.junit.Test;
29+
import org.junit.experimental.categories.Category;
30+
31+
/**
32+
* Testcase for HBASE-23682.
33+
*/
34+
@Category({ MasterTests.class, MediumTests.class })
35+
public class TestDeadServerMetricRegionChore {
36+
37+
@ClassRule
38+
public static final HBaseClassTestRule CLASS_RULE =
39+
HBaseClassTestRule.forClass(TestDeadServerMetricRegionChore.class);
40+
41+
protected HBaseTestingUtility util;
42+
43+
@Before
44+
public void setUp() throws Exception {
45+
util = new HBaseTestingUtility();
46+
// Disable DeadServerMetricRegionChore
47+
util.getConfiguration()
48+
.setInt(AssignmentManager.DEAD_REGION_METRIC_CHORE_INTERVAL_MSEC_CONF_KEY, -1);
49+
}
50+
51+
@After
52+
public void tearDown() throws Exception {
53+
this.util.shutdownMiniCluster();
54+
}
55+
56+
@Test
57+
public void testDeadServerMetricRegionChore() throws Exception {
58+
try {
59+
this.util.startMiniCluster();
60+
} catch (Exception e) {
61+
fail("Start cluster failed");
62+
}
63+
}
64+
65+
}

0 commit comments

Comments
 (0)