|
@@ -53,6 +53,7 @@ import org.apache.hadoop.hdfs.server.protocol.KeyUpdateCommand;
|
|
|
import org.apache.hadoop.hdfs.server.protocol.NamespaceInfo;
|
|
|
import org.apache.hadoop.hdfs.server.protocol.ReceivedDeletedBlockInfo;
|
|
|
import org.apache.hadoop.hdfs.server.protocol.UpgradeCommand;
|
|
|
+import org.apache.hadoop.io.IOUtils;
|
|
|
import org.apache.hadoop.ipc.RPC;
|
|
|
import org.apache.hadoop.ipc.RemoteException;
|
|
|
import org.apache.hadoop.util.StringUtils;
|
|
@@ -447,7 +448,7 @@ class BPOfferService implements Runnable {
|
|
|
if(upgradeManager != null)
|
|
|
upgradeManager.shutdownUpgrade();
|
|
|
shouldServiceRun = false;
|
|
|
- RPC.stopProxy(bpNamenode);
|
|
|
+ IOUtils.cleanup(LOG, bpNamenode);
|
|
|
dn.shutdownBlockPool(this);
|
|
|
}
|
|
|
|