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 GitHub
parent c120260bce
commit b4a4debdd9
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
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 { throws IOException {
this.server = master; this.server = master;
this.conf = conf; 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 = this.choreService =
new ChoreService(name + ".splitLogManager."); new ChoreService(master.getServerName().toShortString() + ".splitLogManager.");
if (server.getCoordinatedStateManager() != null) { if (server.getCoordinatedStateManager() != null) {
SplitLogManagerCoordination coordination = getSplitLogManagerCoordination(); SplitLogManagerCoordination coordination = getSplitLogManagerCoordination();
Set<String> failedDeletions = Collections.synchronizedSet(new HashSet<String>()); Set<String> failedDeletions = Collections.synchronizedSet(new HashSet<String>());

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

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