Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Clean shared state pollution to avoid flaky tests.

This commit is contained in:
Yang Chen 2021-08-19 11:38:08 +08:00
parent f2e2140b57
commit 3a1d467f1d
2 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
hbase-server/src/main/java/org/apache/hadoop/hbase/monitoring/TaskMonitor.java
View File

@ -243,6 +243,11 @@ public class TaskMonitor {
} }
} }
public synchronized void purgeAllTasks() {
tasks.clear();
rpcTasks.clear();
}
/** /**
* This class encapsulates an object as well as a weak reference to a proxy * This class encapsulates an object as well as a weak reference to a proxy
* that passes through calls to that object. In art form: * that passes through calls to that object. In art form:

1
hbase-server/src/test/java/org/apache/hadoop/hbase/monitoring/TestTaskMonitor.java
View File

@ -142,6 +142,7 @@ public class TestTaskMonitor {
} }
assertEquals("RPC Tasks have been purged!", RPCTaskNums, remainRPCTask); assertEquals("RPC Tasks have been purged!", RPCTaskNums, remainRPCTask);
tm.shutdown(); tm.shutdown();
tm.purgeAllTasks();
} }
@Test @Test