YARN-3537. NPE when NodeManager.serviceInit fails and stopRecoveryStore invoked. Contributed by Brahma Reddy Battula
This commit is contained in:
parent
5ce3a77f3c
commit
5e093f0d40
@ -290,6 +290,9 @@ Release 2.7.1 - UNRELEASED
|
|||||||
YARN-3522. Fixed DistributedShell to instantiate TimeLineClient as the
|
YARN-3522. Fixed DistributedShell to instantiate TimeLineClient as the
|
||||||
correct user. (Zhijie Shen via jianhe)
|
correct user. (Zhijie Shen via jianhe)
|
||||||
|
|
||||||
|
YARN-3537. NPE when NodeManager.serviceInit fails and stopRecoveryStore
|
||||||
|
invoked (Brahma Reddy Battula via jlowe)
|
||||||
|
|
||||||
Release 2.7.0 - 2015-04-20
|
Release 2.7.0 - 2015-04-20
|
||||||
|
|
||||||
INCOMPATIBLE CHANGES
|
INCOMPATIBLE CHANGES
|
||||||
|
@ -178,6 +178,7 @@ private void initAndStartRecoveryStore(Configuration conf)
|
|||||||
}
|
}
|
||||||
|
|
||||||
private void stopRecoveryStore() throws IOException {
|
private void stopRecoveryStore() throws IOException {
|
||||||
|
if (null != nmStore) {
|
||||||
nmStore.stop();
|
nmStore.stop();
|
||||||
if (null != context) {
|
if (null != context) {
|
||||||
if (context.getDecommissioned() && nmStore.canRecover()) {
|
if (context.getDecommissioned() && nmStore.canRecover()) {
|
||||||
@ -194,6 +195,7 @@ private void stopRecoveryStore() throws IOException {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
|
||||||
private void recoverTokens(NMTokenSecretManagerInNM nmTokenSecretManager,
|
private void recoverTokens(NMTokenSecretManagerInNM nmTokenSecretManager,
|
||||||
NMContainerTokenSecretManager containerTokenSecretManager)
|
NMContainerTokenSecretManager containerTokenSecretManager)
|
||||||
|
Loading…
Reference in New Issue
Block a user