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