YARN-6798. Fix NM startup failure with old state store due to version mismatch. (Botong Huang via rchiang)
Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/f5f14a2a Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/f5f14a2a Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/f5f14a2a Branch: refs/heads/HDFS-7240 Commit: f5f14a2ad67f91064a73685b44369c6314f0e1cd Parents: 0b7afc0 Author: Ray Chiang <[email protected]> Authored: Tue Jul 18 12:35:08 2017 -0700 Committer: Ray Chiang <[email protected]> Committed: Tue Jul 18 12:35:08 2017 -0700 ---------------------------------------------------------------------- .../nodemanager/recovery/NMLeveldbStateStoreService.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/f5f14a2a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/recovery/NMLeveldbStateStoreService.java ---------------------------------------------------------------------- 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 a0502df..c556b39 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,7 +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"; - private static final Version CURRENT_VERSION_INFO = Version.newInstance(3, 0); + /** + * 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_"; --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
