|
@@ -820,6 +820,14 @@ public class ResourceSchedulerWrapper
|
|
|
((AbstractYarnScheduler<SchedulerApplicationAttempt, SchedulerNode>)
|
|
|
scheduler).init(conf);
|
|
|
super.serviceInit(conf);
|
|
|
+ initScheduler(conf);
|
|
|
+ }
|
|
|
+
|
|
|
+ private synchronized void initScheduler(Configuration configuration) throws
|
|
|
+ IOException {
|
|
|
+ this.applications =
|
|
|
+ new ConcurrentHashMap<ApplicationId,
|
|
|
+ SchedulerApplication<SchedulerApplicationAttempt>>();
|
|
|
}
|
|
|
|
|
|
@SuppressWarnings("unchecked")
|