File tree Expand file tree Collapse file tree 1 file changed +5
-1
lines changed
hadoop-tools/hadoop-sls/src/main/java/org/apache/hadoop/yarn/sls Expand file tree Collapse file tree 1 file changed +5
-1
lines changed Original file line number Diff line number Diff line change 8585import org .apache .hadoop .yarn .sls .nodemanager .NMSimulator ;
8686import org .apache .hadoop .yarn .sls .resourcemanager .MockAMLauncher ;
8787import org .apache .hadoop .yarn .sls .scheduler .SLSCapacityScheduler ;
88+ import org .apache .hadoop .yarn .sls .scheduler .SchedulerMetrics ;
8889import org .apache .hadoop .yarn .sls .scheduler .TaskRunner ;
8990import org .apache .hadoop .yarn .sls .scheduler .SLSFairScheduler ;
9091import org .apache .hadoop .yarn .sls .scheduler .ContainerSimulator ;
@@ -779,7 +780,10 @@ private void increaseQueueAppNum(String queue) throws YarnException {
779780 }
780781
781782 queueAppNumMap .put (queueName , appNum );
782- wrapper .getSchedulerMetrics ().trackQueue (queueName );
783+ SchedulerMetrics metrics = wrapper .getSchedulerMetrics ();
784+ if (metrics != null ) {
785+ metrics .trackQueue (queueName );
786+ }
783787 }
784788
785789 private void runNewAM (String jobType , String user ,
You can’t perform that action at this time.
0 commit comments