HDFS-16241. Standby close reconstruction thread (#3493)
Co-authored-by: zhanghuazong <Zhz@20068867>
This commit is contained in:
parent
b1ad4eab9a
commit
88d8c3d0c8
|
@ -3647,7 +3647,7 @@ public class BlockManager implements BlockStatsMXBean {
|
|||
/*
|
||||
* Stop the ongoing initialisation of reconstruction queues
|
||||
*/
|
||||
private void stopReconstructionInitializer() {
|
||||
public void stopReconstructionInitializer() {
|
||||
if (reconstructionQueuesInitializer != null) {
|
||||
reconstructionQueuesInitializer.interrupt();
|
||||
try {
|
||||
|
|
|
@ -1458,8 +1458,11 @@ public class FSNamesystem implements Namesystem, FSNamesystemMBean,
|
|||
LOG.info("Stopping services started for active state");
|
||||
writeLock();
|
||||
try {
|
||||
if (blockManager != null && blockManager.getSPSManager() != null) {
|
||||
blockManager.getSPSManager().stop();
|
||||
if (blockManager != null) {
|
||||
blockManager.stopReconstructionInitializer();
|
||||
if (blockManager.getSPSManager() != null) {
|
||||
blockManager.getSPSManager().stop();
|
||||
}
|
||||
}
|
||||
stopSecretManager();
|
||||
leaseManager.stopMonitor();
|
||||
|
|
Loading…
Reference in New Issue