diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-services/hadoop-yarn-services-core/src/main/java/org/apache/hadoop/yarn/service/ServiceScheduler.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-services/hadoop-yarn-services-core/src/main/java/org/apache/hadoop/yarn/service/ServiceScheduler.java index fa94491ec4c..b0ff69139b4 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-services/hadoop-yarn-services-core/src/main/java/org/apache/hadoop/yarn/service/ServiceScheduler.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-services/hadoop-yarn-services-core/src/main/java/org/apache/hadoop/yarn/service/ServiceScheduler.java @@ -708,6 +708,12 @@ public void onContainersReceivedFromPreviousAttempts( } for (Container container : containers) { ComponentInstance compInstance; + compInstance = liveInstances.get(container.getId()); + if (compInstance != null) { + LOG.info("Ignore, container {} is being used for {}", + container.getId(), compInstance.getCompInstanceName()); + continue; + } synchronized (unRecoveredInstances) { compInstance = unRecoveredInstances.remove(container.getId()); }