|
@@ -306,10 +306,12 @@ public class FairScheduler extends
|
|
|
private void dumpSchedulerState() {
|
|
|
FSQueue rootQueue = queueMgr.getRootQueue();
|
|
|
Resource clusterResource = getClusterResource();
|
|
|
- LOG.debug("FairScheduler state: Cluster Capacity: " + clusterResource +
|
|
|
+ STATE_DUMP_LOG.debug(
|
|
|
+ "FairScheduler state: Cluster Capacity: " + clusterResource +
|
|
|
" Allocations: " + rootMetrics.getAllocatedResources() +
|
|
|
" Availability: " + Resource.newInstance(
|
|
|
- rootMetrics.getAvailableMB(), rootMetrics.getAvailableVirtualCores()) +
|
|
|
+ rootMetrics.getAvailableMB(),
|
|
|
+ rootMetrics.getAvailableVirtualCores()) +
|
|
|
" Demand: " + rootQueue.getDemand());
|
|
|
|
|
|
STATE_DUMP_LOG.debug(rootQueue.dumpState());
|
|
@@ -350,7 +352,7 @@ public class FairScheduler extends
|
|
|
}
|
|
|
|
|
|
// Log debug information
|
|
|
- if (LOG.isDebugEnabled()) {
|
|
|
+ if (STATE_DUMP_LOG.isDebugEnabled()) {
|
|
|
if (--updatesToSkipForDebug < 0) {
|
|
|
updatesToSkipForDebug = UPDATE_DEBUG_FREQUENCY;
|
|
|
dumpSchedulerState();
|