diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/recovery/NMLeveldbStateStoreService.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/recovery/NMLeveldbStateStoreService.java index f1e47c70603..c556b39d165 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/recovery/NMLeveldbStateStoreService.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/recovery/NMLeveldbStateStoreService.java @@ -85,10 +85,11 @@ public class NMLeveldbStateStoreService extends NMStateStoreService { private static final String DB_NAME = "yarn-nm-state"; private static final String DB_SCHEMA_VERSION_KEY = "nm-schema-version"; - // Set to 1.1 by YARN-5049 - // Set to 1.2 by YARN-6127 - private static final Version CURRENT_VERSION_INFO = Version - .newInstance(1, 2); + /** + * Changes from 1.0 to 1.1: Save AMRMProxy state in NMSS. + * Changes from 1.2 to 1.2: Save queued container information. + */ + private static final Version CURRENT_VERSION_INFO = Version.newInstance(1, 2); private static final String DELETION_TASK_KEY_PREFIX = "DeletionService/deltask_"; @@ -491,8 +492,8 @@ public class NMLeveldbStateStoreService extends NMStateStoreService { batch.delete(bytes(keyPrefix + CONTAINER_QUEUED_KEY_SUFFIX)); batch.delete(bytes(keyPrefix + CONTAINER_KILLED_KEY_SUFFIX)); batch.delete(bytes(keyPrefix + CONTAINER_EXIT_CODE_KEY_SUFFIX)); - List unknownKeysForContainer = - containerUnknownKeySuffixes.removeAll(containerId); + List unknownKeysForContainer = containerUnknownKeySuffixes + .removeAll(containerId); for (String unknownKeySuffix : unknownKeysForContainer) { batch.delete(bytes(keyPrefix + unknownKeySuffix)); }