|
@@ -1427,8 +1427,11 @@ public class FSNamesystem implements Namesystem, FSNamesystemMBean,
|
|
LOG.info("Stopping services started for active state");
|
|
LOG.info("Stopping services started for active state");
|
|
writeLock();
|
|
writeLock();
|
|
try {
|
|
try {
|
|
- if (blockManager != null && blockManager.getSPSManager() != null) {
|
|
|
|
- blockManager.getSPSManager().stop();
|
|
|
|
|
|
+ if (blockManager != null) {
|
|
|
|
+ blockManager.stopReconstructionInitializer();
|
|
|
|
+ if (blockManager.getSPSManager() != null) {
|
|
|
|
+ blockManager.getSPSManager().stop();
|
|
|
|
+ }
|
|
}
|
|
}
|
|
stopSecretManager();
|
|
stopSecretManager();
|
|
leaseManager.stopMonitor();
|
|
leaseManager.stopMonitor();
|