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

HBASE-24475 Clean up the master thread name getting in SplitLogManager and AssignmentManager (#1810)

This commit is contained in:
bsglz 2020-05-31 13:23:04 +08:00 committed by stack
parent 7b17e1cdaa
commit 327d090e1b
2 changed files with 2 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
hbase-server/src/main/java/org/apache/hadoop/hbase/master/SplitLogManager.java
View File

@ -121,12 +121,8 @@ public class SplitLogManager {
throws IOException {
this.server = master;
this.conf = conf;
// Get Server Thread name. Sometimes the Server is mocked so may not extends Thread.
// For example, in tests.
String name = master instanceof Thread? ((Thread)master).getName():
master.getServerName().toShortString();
this.choreService =
new ChoreService(name + ".splitLogManager.");
new ChoreService(master.getServerName().toShortString() + ".splitLogManager.");
if (server.getCoordinatedStateManager() != null) {
SplitLogManagerCoordination coordination = getSplitLogManagerCoordination();
Set<String> failedDeletions = Collections.synchronizedSet(new HashSet<String>());

6
hbase-server/src/main/java/org/apache/hadoop/hbase/master/assignment/AssignmentManager.java
View File

@ -1896,11 +1896,7 @@ public class AssignmentManager {
}
private void startAssignmentThread() {
// Get Server Thread name. Sometimes the Server is mocked so may not implement Thread.
// For example, in tests.
String name = master instanceof Thread? ((Thread)master).getName():
master.getServerName().toShortString();
assignThread = new Thread(name) {
assignThread = new Thread(master.getServerName().toShortString()) {
@Override
public void run() {
while (isRunning()) {