|
@@ -326,9 +326,14 @@ public class NodeManager extends CompositeService
|
|
|
if (isStopping.getAndSet(true)) {
|
|
|
return;
|
|
|
}
|
|
|
- super.serviceStop();
|
|
|
- stopRecoveryStore();
|
|
|
- DefaultMetricsSystem.shutdown();
|
|
|
+ try {
|
|
|
+ super.serviceStop();
|
|
|
+ DefaultMetricsSystem.shutdown();
|
|
|
+ } finally {
|
|
|
+ // YARN-3641: NM's services stop get failed shouldn't block the
|
|
|
+ // release of NMLevelDBStore.
|
|
|
+ stopRecoveryStore();
|
|
|
+ }
|
|
|
}
|
|
|
|
|
|
public String getName() {
|