Repository: hadoop Updated Branches: refs/heads/trunk 36cd0bce8 -> 0a5def155
YARN-4568. Fix message when NodeManager runs into errors initializing the recovery directory. (rchiang) Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/0a5def15 Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/0a5def15 Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/0a5def15 Branch: refs/heads/trunk Commit: 0a5def155eff4564b5dc7685e7460952f51bbd24 Parents: 36cd0bc Author: Ray Chiang <[email protected]> Authored: Fri Jul 1 15:49:30 2016 -0700 Committer: Ray Chiang <[email protected]> Committed: Fri Jul 1 15:53:46 2016 -0700 ---------------------------------------------------------------------- .../apache/hadoop/yarn/server/nodemanager/NodeManager.java | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/0a5def15/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/NodeManager.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/NodeManager.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/NodeManager.java index 6ca7ffe..f7d226e 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/NodeManager.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/NodeManager.java @@ -287,7 +287,14 @@ public class NodeManager extends CompositeService .RM_WORK_PRESERVING_RECOVERY_ENABLED, YarnConfiguration.DEFAULT_RM_WORK_PRESERVING_RECOVERY_ENABLED); - initAndStartRecoveryStore(conf); + try { + initAndStartRecoveryStore(conf); + } catch (IOException e) { + String recoveryDirName = conf.get(YarnConfiguration.NM_RECOVERY_DIR); + throw new + YarnRuntimeException("Unable to initialize recovery directory at " + + recoveryDirName, e); + } NMContainerTokenSecretManager containerTokenSecretManager = new NMContainerTokenSecretManager(conf, nmStore); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
