YarnConfiguration.DEFAULT_HOPS_DISTRIBUTED_RT_ENABLED)) {</BUG>
LOG.info("streaming porcessor is straring for scheduler");
RMStorageFactory.kickTheNdbEventStreamingAPI(true, conf);
eventRetriever = new NdbEventStreamingProcessor(rmContext, conf);
<BUG>} else {
eventRetriever = new PendingEventRetrievalBatch(rmContext, conf);
}</BUG>
}
this.rmLoginUGI.doAs(new PrivilegedExceptionAction<Void>() {
@Override

resourceTrackingService.stop();
resetDispatcher();
resetTransactionStateManager();
createAndInitSchedulerServices();
if (rmContext.isDistributedEnabled()) {
LOG.info("streaming porcessor is straring for scheduler");
RMStorageFactory.kickTheNdbEventStreamingAPI(true, conf);
eventRetriever = new NdbEventStreamingProcessor(rmContext, conf);
}
this.rmLoginUGI.doAs(new PrivilegedExceptionAction<Void>() {
@Override
