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

HBASE-21376 Add some verbose log to MasterProcedureScheduler

This commit is contained in:
Allan Yang 2018-10-26 05:54:50 -07:00 committed by Michael Stack
parent 127de9e637
commit 71224ee530
No known key found for this signature in database
GPG Key ID: 9816C7FC8ACC93D2
3 changed files with 68 additions and 23 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
hbase-server/src/main/java/org/apache/hadoop/hbase/master/procedure/MasterProcedureEnv.java
View File

@ -82,7 +82,9 @@ public class MasterProcedureEnv implements ConfigurationObserver {
public MasterProcedureEnv(final MasterServices master,
final RSProcedureDispatcher remoteDispatcher) {
this.master = master;
this.procSched = new MasterProcedureScheduler();
boolean verbose = master.getConfiguration()
.getBoolean("hbase.master.procedure.scheduler.verbose", false);
this.procSched = new MasterProcedureScheduler(verbose);
this.remoteDispatcher = remoteDispatcher;
}

78
hbase-server/src/main/java/org/apache/hadoop/hbase/master/procedure/MasterProcedureScheduler.java
View File

@ -116,6 +116,16 @@ public class MasterProcedureScheduler extends AbstractProcedureScheduler {
private final SchemaLocking locking = new SchemaLocking();
private boolean verbose = false;
public MasterProcedureScheduler() {
}
public MasterProcedureScheduler(boolean verbose) {
this.verbose = verbose;
}
@Override
public void yield(final Procedure proc) {
push(proc, isTableProcedure(proc), true);
@ -147,11 +157,11 @@ public class MasterProcedureScheduler extends AbstractProcedureScheduler {
if (!queue.getLockStatus().hasExclusiveLock()) {
// if the queue was not remove for an xlock execution,put the queue back into execution
queue.add(proc, addFront);
addToRunQueue(fairq, queue);
addToRunQueue(fairq, queue, proc, "queue doesn't have exclusivelock");
} else if (queue.getLockStatus().hasLockAccess(proc)) {
// always add it to front as the have the lock access.
queue.add(proc, true);
addToRunQueue(fairq, queue);
addToRunQueue(fairq, queue, proc, "procedure has lock access");
} else {
queue.add(proc, addFront);
}
@ -185,6 +195,9 @@ public class MasterProcedureScheduler extends AbstractProcedureScheduler {
private <T extends Comparable<T>> Procedure<?> doPoll(final FairQueue<T> fairq) {
final Queue<T> rq = fairq.poll();
if (rq == null || !rq.isAvailable()) {
if (verbose && rq != null) {
LOG.debug("polled from {} but it is not available", rq);
}
return null;
}
@ -195,20 +208,30 @@ public class MasterProcedureScheduler extends AbstractProcedureScheduler {
final boolean xlockReq = rq.requireExclusiveLock(pollResult);
if (xlockReq && rq.getLockStatus().isLocked() && !rq.getLockStatus().hasLockAccess(pollResult)) {
// someone is already holding the lock (e.g. shared lock). avoid a yield
removeFromRunQueue(fairq, rq);
removeFromRunQueue(fairq, rq, pollResult,
"exclusive lock not acquired: " + rq.getLockStatus());
return null;
}
rq.poll();
if (rq.isEmpty() || xlockReq) {
removeFromRunQueue(fairq, rq);
String why = "";
if (rq.isEmpty()) {
why += "runqueue is empty ";
}
if (xlockReq) {
why += "xlock is required for next procedure";
}
removeFromRunQueue(fairq, rq, pollResult, why);
} else if (rq.getLockStatus().hasParentLock(pollResult)) {
// if the rq is in the fairq because of runnable child
// check if the next procedure is still a child.
// if not, remove the rq from the fairq and go back to the xlock state
Procedure<?> nextProc = rq.peek();
if (nextProc != null && !Procedure.haveSameParent(nextProc, pollResult)) {
removeFromRunQueue(fairq, rq);
removeFromRunQueue(fairq, rq, pollResult,
" parent holds the lock and the next one is not the child of the parent, next procid="
+ nextProc.getProcId());
}
}
@ -269,7 +292,9 @@ public class MasterProcedureScheduler extends AbstractProcedureScheduler {
while (treeMap != null) {
Queue<T> node = AvlTree.getFirst(treeMap);
treeMap = AvlTree.remove(treeMap, node.getKey(), comparator);
if (fairq != null) removeFromRunQueue(fairq, node);
if (fairq != null) {
removeFromRunQueue(fairq, node, null, "clear is called");
}
}
}
@ -326,16 +351,25 @@ public class MasterProcedureScheduler extends AbstractProcedureScheduler {
}
}
private static <T extends Comparable<T>> void addToRunQueue(FairQueue<T> fairq, Queue<T> queue) {
private <T extends Comparable<T>> void addToRunQueue(
FairQueue<T> fairq, Queue<T> queue, final Procedure proc, String why) {
if (!AvlIterableList.isLinked(queue) && !queue.isEmpty()) {
fairq.add(queue);
if (verbose) {
LOG.debug("Adding {} to runqueue, triggered by {}, since {}",
queue.getKey(), proc, why);
}
}
}
private static <T extends Comparable<T>> void removeFromRunQueue(
FairQueue<T> fairq, Queue<T> queue) {
private <T extends Comparable<T>> void removeFromRunQueue(
FairQueue<T> fairq, Queue<T> queue, final Procedure proc, String why) {
if (AvlIterableList.isLinked(queue)) {
fairq.remove(queue);
if (verbose) {
LOG.debug("Remove {} from runqueue, triggered by {}, since {}",
queue.getKey(), proc, why);
}
}
}
@ -403,7 +437,7 @@ public class MasterProcedureScheduler extends AbstractProcedureScheduler {
LockAndQueue lock = locking.getServerLock(serverName);
if (node.isEmpty() && lock.tryExclusiveLock(proc)) {
removeFromRunQueue(serverRunQueue, node);
removeFromRunQueue(serverRunQueue, node, proc, "tryCleanupServerQueue is called");
removeServerQueue(serverName);
}
} finally {
@ -531,7 +565,8 @@ public class MasterProcedureScheduler extends AbstractProcedureScheduler {
logLockedResource(LockedResourceType.TABLE, table.getNameAsString());
return true;
}
removeFromRunQueue(tableRunQueue, getTableQueue(table));
removeFromRunQueue(tableRunQueue, getTableQueue(table), procedure,
"need to wait TableExclusiveLock, lockstatus=" + tableLock);
return false;
} finally {
schedUnlock();
@ -555,7 +590,8 @@ public class MasterProcedureScheduler extends AbstractProcedureScheduler {
if (namespaceLock.releaseSharedLock()) {
waitingCount += wakeWaitingProcedures(namespaceLock);
}
addToRunQueue(tableRunQueue, getTableQueue(table));
addToRunQueue(tableRunQueue, getTableQueue(table), procedure,
"table's exclusive lock is available");
wakePollIfNeeded(waitingCount);
} finally {
schedUnlock();
@ -607,7 +643,8 @@ public class MasterProcedureScheduler extends AbstractProcedureScheduler {
final LockAndQueue tableLock = locking.getTableLock(table);
int waitingCount = 0;
if (tableLock.releaseSharedLock()) {
addToRunQueue(tableRunQueue, getTableQueue(table));
addToRunQueue(tableRunQueue, getTableQueue(table), procedure,
"table's shard lock is available");
waitingCount += wakeWaitingProcedures(tableLock);
}
if (namespaceLock.releaseSharedLock()) {
@ -815,7 +852,8 @@ public class MasterProcedureScheduler extends AbstractProcedureScheduler {
waitingCount += wakeWaitingProcedures(namespaceLock);
}
if (systemNamespaceTableLock.releaseSharedLock()) {
addToRunQueue(tableRunQueue, getTableQueue(TableName.NAMESPACE_TABLE_NAME));
addToRunQueue(tableRunQueue, getTableQueue(TableName.NAMESPACE_TABLE_NAME), procedure,
"namespace exclusive lock is available");
waitingCount += wakeWaitingProcedures(systemNamespaceTableLock);
}
wakePollIfNeeded(waitingCount);
@ -845,7 +883,9 @@ public class MasterProcedureScheduler extends AbstractProcedureScheduler {
removeFromRunQueue(serverRunQueue,
getServerQueue(serverName,
procedure instanceof ServerProcedureInterface ? (ServerProcedureInterface) procedure
: null));
: null), procedure,
"need to wait ServerExclusiveLock, ownerid=" + lock
.getExclusiveLockProcIdOwner());
return false;
}
waitProcedure(lock, procedure);
@ -873,7 +913,7 @@ public class MasterProcedureScheduler extends AbstractProcedureScheduler {
addToRunQueue(serverRunQueue,
getServerQueue(serverName,
procedure instanceof ServerProcedureInterface ? (ServerProcedureInterface) procedure
: null));
: null), procedure, "Server's exclusive lock is available");
int waitingCount = wakeWaitingProcedures(lock);
wakePollIfNeeded(waitingCount);
} finally {
@ -948,7 +988,8 @@ public class MasterProcedureScheduler extends AbstractProcedureScheduler {
try {
final LockAndQueue lock = locking.getMetaLock();
if (lock.tryExclusiveLock(procedure)) {
removeFromRunQueue(metaRunQueue, getMetaQueue());
removeFromRunQueue(metaRunQueue, getMetaQueue(), procedure,
"need to wait MetaExclusiveLock, lockStatus=" + lock);
return false;
}
waitProcedure(lock, procedure);
@ -972,7 +1013,8 @@ public class MasterProcedureScheduler extends AbstractProcedureScheduler {
try {
final LockAndQueue lock = locking.getMetaLock();
lock.releaseExclusiveLock(procedure);
addToRunQueue(metaRunQueue, getMetaQueue());
addToRunQueue(metaRunQueue, getMetaQueue(), procedure,
"meta's exclusive lock is available");
int waitingCount = wakeWaitingProcedures(lock);
wakePollIfNeeded(waitingCount);
} finally {

9
hbase-server/src/main/java/org/apache/hadoop/hbase/master/procedure/Queue.java
View File

@ -118,9 +118,10 @@ abstract class Queue<TKey extends Comparable<TKey>> extends AvlLinkedNode<Queue<
@Override
public String toString() {
return String.format("%s(%s, xlock=%s sharedLock=%s size=%s)", getClass().getSimpleName(), key,
lockStatus.hasExclusiveLock() ? "true (" + lockStatus.getExclusiveLockProcIdOwner() + ")"
: "false",
lockStatus.getSharedLockCount(), size());
return String.format("%s(%s, xlock=%s sharedLock=%s size=%s peek=%s)",
getClass().getSimpleName(), key, lockStatus.hasExclusiveLock() ?
"true (" + lockStatus.getExclusiveLockProcIdOwner() + ")" :
"false", lockStatus.getSharedLockCount(), size(),
(size() > 0 ? peek() : "null"));
}
}