Apache
/
hadoop
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HDFS-16241. Standby close reconstruction thread (#3493) 

Co-authored-by: zhanghuazong <Zhz@20068867>
(cherry picked from commit 88d8c3d0c8)
(cherry picked from commit a35a6ec06b)
This commit is contained in:
langlaile1221 2021-10-11 16:11:31 +08:00 committed by Wei-Chiu Chuang
parent 675712afa3
commit 88744b8a04
No known key found for this signature in database
GPG Key ID: B362E1C021854B9D
2 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/BlockManager.java
View File

@ -3562,7 +3562,7 @@ public class BlockManager implements BlockStatsMXBean {
/* /*
* Stop the ongoing initialisation of reconstruction queues * Stop the ongoing initialisation of reconstruction queues
*/ */
private void stopReconstructionInitializer() { public void stopReconstructionInitializer() {
if (reconstructionQueuesInitializer != null) { if (reconstructionQueuesInitializer != null) {
reconstructionQueuesInitializer.interrupt(); reconstructionQueuesInitializer.interrupt();
try { try {

7
hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/FSNamesystem.java
View File

@ -1365,8 +1365,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) { if (blockManager != null) {
blockManager.getSPSManager().stop(); blockManager.stopReconstructionInitializer();
if (blockManager.getSPSManager() != null) {
blockManager.getSPSManager().stop();
}
} }
stopSecretManager(); stopSecretManager();
leaseManager.stopMonitor(); leaseManager.stopMonitor();