Если ваш уровень журнала установлен на info
, вы должны увидеть это в журналах менеджера ресурсов YARN.
// Warn application about containers to be killed
for (RMContainer container : containers) {
FSAppAttempt app = scheduler.getSchedulerApp(
container.getApplicationAttemptId());
LOG.info("Preempting container " + container +
" from queue " + app.getQueueName());
app.trackContainerForPreemption(container);
}
при https://github.com/apache/hadoop/.../scheduler/fair/FSPreemptionThread.java#L143.
А если у вас уровень журнала debug
, вы также увидите это:
if (LOG.isDebugEnabled()) {
LOG.debug(
"allocate: post-update" + " applicationAttemptId=" + appAttemptId
+ " #ask=" + ask.size() + " reservation= " + application
.getCurrentReservation());
LOG.debug("Preempting " + preemptionContainerIds.size()
+ " container(s)");
}
в https://github.com/apache/hadoop/.../scheduler/fair/FairScheduler.java#937